Skip to content
This repository was archived by the owner on Jul 11, 2023. It is now read-only.

Commit b54bf29

Browse files
chris-morganpcwalton
authored andcommitted
Update for upstream Stream changes.
With the landing of rust-lang/rust#8984, we can finally use Stream meaningfully...
1 parent b633d1e commit b54bf29

File tree

3 files changed

+6
-6
lines changed

3 files changed

+6
-6
lines changed

src/libhttp/buffer.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ struct BufferedStream<T> {
3232
writing_chunked_body: bool,
3333
}
3434

35-
impl<T: Reader + Writer /*Stream*/> BufferedStream<T> {
35+
impl<T: Stream> BufferedStream<T> {
3636
pub fn new(stream: T, call_wrapped_flush: bool) -> BufferedStream<T> {
3737
BufferedStream {
3838
wrapped: stream,

src/libhttp/client/response.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
use std::rt::io::{Reader, Writer};
1+
use std::rt::io::{Reader, Stream};
22
use std::rt::io::extensions::ReaderUtil;
33
use std::rt::io::{io_error, OtherIoError, IoError};
44
use client::request::RequestWriter;
@@ -36,7 +36,7 @@ fn bad_response_err() -> IoError {
3636
}
3737
}
3838

39-
impl<S: Reader + Writer> ResponseReader<S> {
39+
impl<S: Stream> ResponseReader<S> {
4040
pub fn construct(mut stream: BufferedStream<S>, request: ~RequestWriter<S>)
4141
-> Result<ResponseReader<S>, ~RequestWriter<S>> {
4242
// TODO: raise condition at the points where Err is returned
@@ -143,7 +143,7 @@ impl<S: Reader + Writer> ResponseReader<S> {
143143
}
144144
}
145145

146-
impl<S: Reader + Writer> Reader for ResponseReader<S> {
146+
impl<S: Stream> Reader for ResponseReader<S> {
147147
fn read(&mut self, buf: &mut [u8]) -> Option<uint> {
148148
self.stream.read(buf)
149149
}

src/libhttp/server/request.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
use extra::url::Url;
22
use method::{Method, Options};
33
use status;
4-
use std::rt::io::{Reader, Writer};
4+
use std::rt::io::Stream;
55
use std::rt::io::net::ip::SocketAddr;
66
use rfc2616::{CR, LF, SP};
77
use headers;
@@ -29,7 +29,7 @@ pub struct RequestBuffer<'self, S> {
2929
line_bytes: ~[u8],
3030
}
3131

32-
impl<'self, S: Reader + Writer> RequestBuffer<'self, S> {
32+
impl<'self, S: Stream> RequestBuffer<'self, S> {
3333
pub fn new<'a>(stream: &'a mut BufferedStream<S>) -> RequestBuffer<'a, S> {
3434
RequestBuffer {
3535
stream: stream,

0 commit comments

Comments
 (0)