Cosmetics.
This commit is contained in:
parent
3b8c6dfd4c
commit
ae0a155a39
|
@ -325,11 +325,9 @@ public class StandardSession implements ISession, Parser.Listener, Handler<Stand
|
||||||
public void run()
|
public void run()
|
||||||
{
|
{
|
||||||
stream.handle(frame, data);
|
stream.handle(frame, data);
|
||||||
|
updateLastStreamId(stream);
|
||||||
if (stream.isClosed())
|
if (stream.isClosed())
|
||||||
{
|
|
||||||
updateLastStreamId(stream);
|
|
||||||
removeStream(stream);
|
removeStream(stream);
|
||||||
}
|
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
@ -687,7 +685,7 @@ public class StandardSession implements ISession, Parser.Listener, Handler<Stand
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
if (stream != null)
|
if (stream != null)
|
||||||
updateLastStreamId(stream); // TODO: not sure this is right
|
updateLastStreamId(stream);
|
||||||
|
|
||||||
// Synchronization is necessary, since we may have concurrent replies
|
// Synchronization is necessary, since we may have concurrent replies
|
||||||
// and those needs to be generated and enqueued atomically in order
|
// and those needs to be generated and enqueued atomically in order
|
||||||
|
|
Loading…
Reference in New Issue