diff options
Diffstat (limited to 'jetty-spdy/spdy-core/src/main/java/org/eclipse/jetty/spdy/StandardStream.java')
-rw-r--r-- | jetty-spdy/spdy-core/src/main/java/org/eclipse/jetty/spdy/StandardStream.java | 20 |
1 files changed, 10 insertions, 10 deletions
diff --git a/jetty-spdy/spdy-core/src/main/java/org/eclipse/jetty/spdy/StandardStream.java b/jetty-spdy/spdy-core/src/main/java/org/eclipse/jetty/spdy/StandardStream.java index 360a639591..3db6a14a34 100644 --- a/jetty-spdy/spdy-core/src/main/java/org/eclipse/jetty/spdy/StandardStream.java +++ b/jetty-spdy/spdy-core/src/main/java/org/eclipse/jetty/spdy/StandardStream.java @@ -22,7 +22,6 @@ import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicInteger; import org.eclipse.jetty.spdy.api.DataInfo; -import org.eclipse.jetty.spdy.api.Handler; import org.eclipse.jetty.spdy.api.HeadersInfo; import org.eclipse.jetty.spdy.api.ReplyInfo; import org.eclipse.jetty.spdy.api.RstInfo; @@ -33,6 +32,7 @@ import org.eclipse.jetty.spdy.api.SynInfo; import org.eclipse.jetty.spdy.frames.ControlFrame; import org.eclipse.jetty.spdy.frames.HeadersFrame; import org.eclipse.jetty.spdy.frames.SynReplyFrame; +import org.eclipse.jetty.util.Callback; import org.eclipse.jetty.util.log.Log; import org.eclipse.jetty.util.log.Logger; @@ -318,15 +318,15 @@ public class StandardStream implements IStream } @Override - public void syn(SynInfo synInfo, long timeout, TimeUnit unit, Handler<Stream> handler) + public void syn(SynInfo synInfo, long timeout, TimeUnit unit, Callback<Stream> callback) { if (isClosed() || isReset()) { - handler.failed(this, new StreamException(getId(), StreamStatus.STREAM_ALREADY_CLOSED)); + callback.failed(this, new StreamException(getId(), StreamStatus.STREAM_ALREADY_CLOSED)); return; } PushSynInfo pushSynInfo = new PushSynInfo(getId(), synInfo); - session.syn(pushSynInfo, null, timeout, unit, handler); + session.syn(pushSynInfo, null, timeout, unit, callback); } @Override @@ -338,14 +338,14 @@ public class StandardStream implements IStream } @Override - public void reply(ReplyInfo replyInfo, long timeout, TimeUnit unit, Handler<Void> handler) + public void reply(ReplyInfo replyInfo, long timeout, TimeUnit unit, Callback<Void> callback) { if (isUnidirectional()) throw new IllegalStateException("Protocol violation: cannot send SYN_REPLY frames in unidirectional streams"); openState = OpenState.REPLY_SENT; updateCloseState(replyInfo.isClose(), true); SynReplyFrame frame = new SynReplyFrame(session.getVersion(), replyInfo.getFlags(), getId(), replyInfo.getHeaders()); - session.control(this, frame, timeout, unit, handler, null); + session.control(this, frame, timeout, unit, callback, null); } @Override @@ -357,7 +357,7 @@ public class StandardStream implements IStream } @Override - public void data(DataInfo dataInfo, long timeout, TimeUnit unit, Handler<Void> handler) + public void data(DataInfo dataInfo, long timeout, TimeUnit unit, Callback<Void> callback) { if (!canSend()) { @@ -372,7 +372,7 @@ public class StandardStream implements IStream // Cannot update the close state here, because the data that we send may // be flow controlled, so we need the stream to update the window size. - session.data(this, dataInfo, timeout, unit, handler, null); + session.data(this, dataInfo, timeout, unit, callback, null); } @Override @@ -384,7 +384,7 @@ public class StandardStream implements IStream } @Override - public void headers(HeadersInfo headersInfo, long timeout, TimeUnit unit, Handler<Void> handler) + public void headers(HeadersInfo headersInfo, long timeout, TimeUnit unit, Callback<Void> callback) { if (!canSend()) { @@ -399,7 +399,7 @@ public class StandardStream implements IStream updateCloseState(headersInfo.isClose(), true); HeadersFrame frame = new HeadersFrame(session.getVersion(), headersInfo.getFlags(), getId(), headersInfo.getHeaders()); - session.control(this, frame, timeout, unit, handler, null); + session.control(this, frame, timeout, unit, callback, null); } @Override |