(env: Envelope)
| 36 | ); |
| 37 | t.attachStreamsForTest(toCore, fromCore); |
| 38 | const feed = (env: Envelope) => { |
| 39 | fromCore.write(sizeDelimitedEncode(EnvelopeSchema, env)); |
| 40 | }; |
| 41 | const reqs = sizeDelimitedDecodeStream(EnvelopeSchema, toCore); |
| 42 | return { t, feed, reqs }; |
| 43 | } |