Permalink
Browse files

Fix doctest for scala 2.11

  • Loading branch information...
zainab-ali committed Sep 14, 2018
1 parent 7c59aca commit 566fdfa9c4e05e3fb4843f56c84791f74c5ba388
Showing with 2 additions and 2 deletions.
  1. +1 −1 reactive-streams/src/main/scala/fs2/interop/reactivestreams/package.scala
  2. +1 −1 site/src/guide.md
@@ -17,7 +17,7 @@ import org.reactivestreams._
* scala> implicit val contextShift: ContextShift[IO] = IO.contextShift(ExecutionContext.global)
* scala>
* scala> val upstream: Stream[IO, Int] = Stream(1, 2, 3).covary[IO]
* scala> val publisher: org.reactivestreams.Publisher[Int] = upstream.toUnicastPublisher
* scala> val publisher: StreamUnicastPublisher[IO, Int] = upstream.toUnicastPublisher
* scala> val downstream: Stream[IO, Int] = publisher.toStream[IO]
* scala>
* scala> downstream.compile.toVector.unsafeRunSync()
@@ -562,7 +562,7 @@ stream.toUnicastPublisher
To convert an upstream `org.reactivestreams.Publisher` into a `Stream`:
```tut:book
val publisher: org.reactivestreams.Publisher[Int] = Stream(1, 2, 3).covary[IO].toUnicastPublisher
val publisher: StreamUnicastPublisher[IO, Int] = Stream(1, 2, 3).covary[IO].toUnicastPublisher
publisher.toStream[IO]
```

0 comments on commit 566fdfa

Please sign in to comment.