StreamEvents method
Stream<StreamEventsResponse>
StreamEvents(
- Stream<
StreamEventsRequest> input, { - Map<
String, dynamic> headers = const {},
Implementation
Stream<StreamEventsResponse> StreamEvents(Stream<StreamEventsRequest> input, {Map<String,dynamic> headers = const {}}) async* {
var socket = await $io.WebSocket.connect(this.wsServer.replace(path: "/protocol.chat.v1.ChatService/StreamEvents").toString(), headers: headers..addAll(this.commonHeaders));
var combined = $async.StreamGroup.merge<dynamic>([socket, input]);
await for (var value in combined) {
if (value is List<int>) {
yield StreamEventsResponse.fromBuffer(value);
} else if (value is StreamEventsRequest) {
socket.add(value.writeToBuffer());
}
}
}