Skip to content

Commit

Permalink
fix little typo
Browse files Browse the repository at this point in the history
  • Loading branch information
Marc Piechura authored Oct 30, 2016
1 parent 2a6e62a commit c09e103
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -170,7 +170,7 @@ class HubSpec extends StreamSpec {
"keep working even if one of the producers fail" in assertAllStagesStopped {
val (sink, result) = MergeHub.source[Int](16).take(10).toMat(Sink.seq)(Keep.both).run()
EventFilter.error("Upstream producer failed with exception").intercept {
Source.failed(TE("faling")).runWith(sink)
Source.failed(TE("failing")).runWith(sink)
Source(1 to 10).runWith(sink)
}

Expand Down

0 comments on commit c09e103

Please sign in to comment.