var metadata = CompositeMetadata.fromEntries([ AuthMetadata.jwt(_token)]);
RSocketConnector.create()
.dataMimeType("application/cbor")
.setupPayload(Payload.from(metadata.toUint8Array(), connectParam.writeToBuffer()) )
.connect('ws://$address')
.then((res) { print('OK') })
.onError((e, stackTrace) { print('Error') })
pub.dev rsocket: ^1.0.0
Callback function then
rsocket.availability() = 1.0
@linux-china 大佬快搞一搞吧