feat: add fused stream implementation

[nappa85]

No description provided.

[nappa85]

No, now I set self to None also when the socket reads an empty buffer Il mar 31 dic 2024, 15:26 Edoardo Morandi ***@***.***> ha scritto:

…

***@***.**** commented on this pull request. ------------------------------ In src/stream.rs <#29 (comment)>: > @@ -90,6 +91,16 @@ impl Stream for UEventsStream { } } - Poll::Pending + if matches!(this, Self::None) { + Poll::Ready(None) + } else { + Poll::Pending This should be unreachable, isn't it? — Reply to this email directly, view it on GitHub <#29 (review)>, or unsubscribe <https://github.com/notifications/unsubscribe-auth/ABZXINO3FFS7KK5HSRJGQPD2IKSPRAVCNFSM6AAAAABUNKBF7CVHI2DSMVQWIX3LMV43YUDVNRWFEZLROVSXG5CSMV3GSZLXHMZDKMRWGUYTANJQG4> . You are receiving this because you authored the thread.Message ID: ***@***.***>

[dodomorandi]

No, now I set self to None also when the socket reads an empty buffer

Yes, but I mean, there is no way this does not match None at that point... or not?

[nappa85]

Ah, yes, the else part... Yes, this should be unreachable, I would prefer a panic over debugging a future that is never waken Il mar 31 dic 2024, 15:30 Edoardo Morandi ***@***.***> ha scritto:

…

No, now I set self to None also when the socket reads an empty buffer Yes, but I mean, there is no way this does *not* match None at that point... or not? — Reply to this email directly, view it on GitHub <#29 (comment)>, or unsubscribe <https://github.com/notifications/unsubscribe-auth/ABZXINJWOJWE2IJN2II7QN32IKTBDAVCNFSM6AAAAABUNKBF7CVHI2DSMVQWIX3LMV43OSLTON2WKQ3PNVWWK3TUHMZDKNRWGQ4TMNZTGY> . You are receiving this because you authored the thread.Message ID: ***@***.***>