messages property

@override Stream<String> get messages

Inbound text frames. The stream completing (done or error) means the connection is gone — the repository reconnects through its transport.

Implementation

@override
Stream<String> get messages =>
    _ws.where((frame) => frame is String).cast<String>().asBroadcastStream();