Silly thing to forget as it's been a major part of previous streaming RPC. Channel implementations currently have no close() method or just call peer.close() which closes the whole connection. This means we'll have to introduce a ctl control type message, but that was inevitable. Later it could be used for back pressure etc.
Silly thing to forget as it's been a major part of previous streaming RPC. Channel implementations currently have no
close()method or just callpeer.close()which closes the whole connection. This means we'll have to introduce actlcontrol type message, but that was inevitable. Later it could be used for back pressure etc.