StreamMessage method

Stream<StreamMessageResponse> StreamMessage(Stream<StreamMessageRequest> input, { Map<String, dynamic> headers = const {}, })

Implementation

Stream<StreamMessageResponse> StreamMessage(Stream<StreamMessageRequest> input, {Map<String,dynamic> headers = const {}}) async* {
	var socket = await $io.WebSocket.connect(this.wsServer.replace(path: "/protocol.voice.v1.VoiceService/StreamMessage").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 StreamMessageResponse.fromBuffer(value);
		} else if (value is StreamMessageRequest) {
			socket.add(value.writeToBuffer());
		}
	}
}