Problems implementing tokio's ServerProto

So, I've been playing around trying to make serde + tokio work. I think I've been having problems wrapping my head around tokio's abstractions and now I've been getting the following compiler error:

playground

This is the first time I literally have no idea what the compiler is trying to tell me. Can some one help?

Thanks!

I think you may have the wrong ServerProto - the multiplex one (what you have there now) requires that the Transport be a Stream<Item=(RequestId, Self::Request)> (amongst other requirements). RequestId is a type alias for u64. But Framed doesn’t fit that.

There’s a ServerProto from the pipeline module whose requirements on Transport are what you’re looking for.

Playground

Huh, I'm feeling silly. I might have copy pasted from somewhere, because I
was sure I was using pipeline.
Thanks!