(&mut self, stream: Resource<DynOutputStream>, bytes: Vec<u8>)
| 129 | } |
| 130 | |
| 131 | fn write(&mut self, stream: Resource<DynOutputStream>, bytes: Vec<u8>) -> StreamResult<()> { |
| 132 | self.get_mut(&stream)?.write(bytes.into())?; |
| 133 | Ok(()) |
| 134 | } |
| 135 | |
| 136 | fn subscribe(&mut self, stream: Resource<DynOutputStream>) -> Result<Resource<DynPollable>> { |
| 137 | subscribe(self, stream) |
no test coverage detected