| 378 | })) |
| 379 | |
| 380 | class StreamRpc extends Rpc.make("StreamTest", { |
| 381 | success: RpcSchema.Stream(Schema.Void, Schema.Never), |
| 382 | payload: { |
| 383 | id: Schema.String |
| 384 | }, |
| 385 | primaryKey: (value) => value.id.toString() |
| 386 | }) {} |
| 387 | |
| 388 | const makeRequest = Effect.fnUntraced(function*(options?: { |
| 389 | readonly payload?: { readonly id: number } |