1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17
package wrpc-examples:streams; interface handler { record req { numbers: stream<u64>, bytes: stream<u8>, } echo: func(r: req) -> (numbers: stream<u64>, bytes: stream<u8>); } world client { import handler; } world server { export handler; }