talksik/nearby_service
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

chore(lib, example_full): naming fixes

Browse Source
This commit is contained in:
ksenia312
2024-02-06 22:26:58 +01:00
parent 66c6f17b99
commit e4a4a542e6
4 changed files with 34 additions and 36 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/src/platforms/android/socket_service/nearby_socket_service.dart
+19 -19
View File
@@ -205,25 +205,25 @@ class NearbySocketService {
.cast<ReceivedNearbyMessage>()
.map((e) => MessagesStreamMapper.replaceId(e, _connectedDeviceId))
.listen(
(message) async {
try {
_handleFilesMessage(message);
socketListener.onData(message);
} catch (e) {
Logger.error(e);
}
},
onDone: () {
state.value = CommunicationChannelState.notConnected;
socketListener.onDone?.call();
},
onError: (e, s) {
Logger.error(e);
state.value = CommunicationChannelState.notConnected;
socketListener.onError?.call(e, s);
},
cancelOnError: socketListener.cancelOnError,
);
(message) async {
try {
_handleFilesMessage(message);
socketListener.onData(message);
} catch (e) {
Logger.error(e);
}
},
onDone: () {
state.value = CommunicationChannelState.notConnected;
socketListener.onDone?.call();
},
onError: (e, s) {
Logger.error(e);
state.value = CommunicationChannelState.notConnected;
socketListener.onError?.call(e, s);
},
cancelOnError: socketListener.cancelOnError,
);
}
if (_messagesSubscription != null) {
state.value = CommunicationChannelState.connected;
lib/src/platforms/ios/nearby_ios_service.dart
+9 -13
View File
@@ -186,23 +186,19 @@ class NearbyIOSService extends NearbyService {
cancelOnError: eventListener.cancelOnError,
);
_resourcesSubscription = NearbyServiceIOSPlatform.instance.resourcesStream
.map((event) {
print(event);
return event;
})
.map(ResourcesStreamMapper.toFilesPack)
.where((event) => event != null)
.cast<ReceivedNearbyFilesPack>()
.listen(
(e) => filesListener?.onData.call(e),
onDone: filesListener?.onDone,
onError: (e, s) {
Logger.error(e);
_state.value = CommunicationChannelState.notConnected;
filesListener?.onError?.call(e, s);
},
cancelOnError: filesListener?.cancelOnError,
);
(e) => filesListener?.onData.call(e),
onDone: filesListener?.onDone,
onError: (e, s) {
Logger.error(e);
_state.value = CommunicationChannelState.notConnected;
filesListener?.onError?.call(e, s);
},
cancelOnError: filesListener?.cancelOnError,
);
if (_messagesSubscription != null) {
Logger.info('Messages subscription was created successfully');
eventListener.onCreated?.call();