streams property
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;
}