@@ -1,5 +1,5 @@
|
|||||||
use codec::{Codec, RecvError};
|
use codec::{Codec, RecvError};
|
||||||
use frame::{Headers, Pseudo, Settings, StreamId};
|
use frame::{Headers, Pseudo, Reason, Settings, StreamId};
|
||||||
use frame::Reason::*;
|
use frame::Reason::*;
|
||||||
use proto::{self, WindowSize};
|
use proto::{self, WindowSize};
|
||||||
|
|
||||||
@@ -345,6 +345,10 @@ impl<B: IntoBuf> Stream<B> {
|
|||||||
pub fn send_trailers(&mut self, trailers: HeaderMap) -> Result<(), ::Error> {
|
pub fn send_trailers(&mut self, trailers: HeaderMap) -> Result<(), ::Error> {
|
||||||
self.inner.send_trailers(trailers).map_err(Into::into)
|
self.inner.send_trailers(trailers).map_err(Into::into)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
pub fn send_reset(mut self, reason: Reason) {
|
||||||
|
self.inner.send_reset(reason)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
impl<B: IntoBuf> Future for Stream<B> {
|
impl<B: IntoBuf> Future for Stream<B> {
|
||||||
|
|||||||
Reference in New Issue
Block a user