Skip to content
Permalink
Browse files

Fixed the test

  • Loading branch information...
shaileshp0110 committed May 15, 2019
1 parent a1f0427 commit 5e5fd220e00d5b555a16d41fc028d85ae2936bfc
Showing with 2 additions and 8 deletions.
  1. +2 −8 src/io/iohk/scalanet/test/peergroup/SimplePeerGroupSpec.scala
@@ -85,37 +85,31 @@ class SimplePeerGroupSpec extends FlatSpec {
val aliceReceivedNews = alice
.server()
.mergeMap { channel =>
channel.in.filter( msg => msg == messageNews)
channel.in.filter(msg => msg == messageNews)
}
.headL
.runToFuture




val messageSports = "Sports Updates"

val aliceMessageSports = alice
.server()
.mergeMap { channel =>
channel.in.filter( msg => msg == messageSports)
channel.in.filter(msg => msg == messageSports)
}
.headL
.runToFuture

val bobClient = bob.client(alice.processAddress).evaluated


bobClient.sendMessage(messageNews).evaluated

aliceReceivedNews.futureValue shouldBe messageNews


bobClient.sendMessage(messageSports).evaluated

aliceMessageSports.futureValue shouldBe messageSports


}
}
}

0 comments on commit 5e5fd22

Please sign in to comment.
You can’t perform that action at this time.