post merge fixes

akkadotnet · Dec 9, 2016 · 00eb888 · 00eb888
1 parent 0f58b36
commit 00eb888
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/src/core/Akka.Streams.Tests/IO/TcpSpec.cs b/src/core/Akka.Streams.Tests/IO/TcpSpec.cs
@@ -118,7 +118,7 @@ public void Outgoing_TCP_stream_must_fail_the_materialized_task_when_the_connect
             }, Materializer);
         }
 
-        [Fact(Skip = "Fix me")]
+        [Fact]
         public void Outgoing_TCP_stream_must_work_when_client_closes_write_then_remote_closes_write()
         {
             this.AssertAllStagesStopped(() =>
@@ -601,19 +601,19 @@ public void Tcp_listen_stream_must_bind_and_unbind_correctly()
             EventFilter.Exception<SocketException>().Expect(2, () =>
             {
                 var address = TestUtils.TemporaryServerAddress();
-                var probe1 = this.CreateProbe<Tcp.IncomingConnection>();
+                var probe1 = this.CreateSubscriberProbe<Tcp.IncomingConnection>();
                 var bind = Sys.TcpStream().Bind(address.Address.ToString(), address.Port);
 
                 // bind suceed, we have local address
                 var binding1 = bind.To(Sink.FromSubscriber(probe1)).Run(Materializer).Result;
 
                 probe1.ExpectSubscription();
 
-                var probe2 = this.CreateManualProbe<Tcp.IncomingConnection>();
+                var probe2 = this.CreateManualSubscriberProbe<Tcp.IncomingConnection>();
                 var binding2F = bind.To(Sink.FromSubscriber(probe2)).Run(Materializer);
                 probe2.ExpectSubscriptionAndError().Should().BeOfType<BindFailedException>();
 
-                var probe3 = this.CreateManualProbe<Tcp.IncomingConnection>();
+                var probe3 = this.CreateManualSubscriberProbe<Tcp.IncomingConnection>();
                 var binding3F = bind.To(Sink.FromSubscriber(probe3)).Run(Materializer);
                 probe3.ExpectSubscriptionAndError().Should().BeOfType<BindFailedException>();
                 
@@ -624,7 +624,7 @@ public void Tcp_listen_stream_must_bind_and_unbind_correctly()
                 binding1.Unbind().Wait(TimeSpan.FromSeconds(3)).Should().BeTrue();
                 probe1.ExpectComplete();
 
-                var probe4 = this.CreateManualProbe<Tcp.IncomingConnection>();
+                var probe4 = this.CreateManualSubscriberProbe<Tcp.IncomingConnection>();
                 // bind succeeded, we have local address
                 var binding4Task = bind.To(Sink.FromSubscriber(probe4)).Run(Materializer);
                 binding4Task.Wait(TimeSpan.FromSeconds(3));