Skip to content
This repository has been archived by the owner on Jan 12, 2021. It is now read-only.

Commit

Permalink
Fix error tests
Browse files Browse the repository at this point in the history
  • Loading branch information
codebje committed Mar 4, 2014
1 parent 49f76a3 commit 8933dab
Showing 1 changed file with 2 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -56,10 +56,9 @@ public void negotiateProtocolVersions() {

channel.writeInbound(new HandshakeMessage(29, 0));

assertThat("There should be a message waiting now", channel.outboundMessages().size(), equalTo(1));
assertThat("There should be a message waiting now", channel.outboundMessages().size(), is(greaterThanOrEqualTo(1)));
Object object = channel.readOutbound();
assertThat("The message available is an ErrorMessage", object, is(instanceOf(ErrorMessage.class)));
assertThat("The error message is an @ERROR", ((ErrorMessage)object).getError(), startsWith("@ERROR: "));
assertThat("The first message available is an ErrorMessage", object, is(instanceOf(ErrorMessage.class)));
assertFalse("The channel should no longer be open", channel.isOpen());
}

Expand Down

0 comments on commit 8933dab

Please sign in to comment.