streams property

  1. @override
Future<List<P2PStream>> get streams
override

GetStreams returns all open streams over this conn.

Implementation

@override
Future<List<libp2p.P2PStream>> get streams async {
  final quicConn = _delegate.quicConnection;
  if (quicConn is! quic_lib.QuicConnection) {
    return [];
  }
  final result = <libp2p.P2PStream>[];
  for (final stream in quicConn.streamManager.streams) {
    if (stream is quic_lib.QuicReceiveStream) {
      result.add(QuicP2PStream(
        this,
        stream.streamId,
        libp2p.Direction.inbound,
        '',
      ));
    }
  }
  return result;
}