Join remains Pending until both streams yield an item

[zeenix]

This code hangs:

            let stream1 = FromStream::with_ordering(pending::<Message>(), |m| m.serial);
            let stream2 = FromStream::with_ordering(
                futures_util::stream::once(Box::pin(async { Message { serial: 1 } })),
                |m| m.serial,
            );
            let mut joined = join(stream1, stream2);
            let msg = joined.next().await.unwrap();
            assert_eq!(msg.serial, 1);

[zeenix]

@danieldg Is this intentional? 🤔

[danieldg]

@danieldg Is this intentional?

Yes, this was intentional. The fix (and therefore the 0.1.3 and 0.1.4 releases) will produce a stream with items out of order if one of the producing streams is being processed by another task or thread.

[zeenix]

Yes, this was intentional. The fix (and therefore the 0.1.3 and 0.1.4 releases) will produce a stream with items out of order if one of the producing streams is being processed by another task or thread.

But this breaks zbus. I want items in order but that doesn't mean I want things to just hang forever to make it happen. I could add a timeout in the client but that's a bad workaround.