Skip to content
Open
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
9 changes: 9 additions & 0 deletions modules/core/src/main/scala/Session.scala
Original file line number Diff line number Diff line change
Expand Up @@ -187,6 +187,10 @@ trait Session[F[_]] {
*/
def describeCache: Describe.Cache[F]

/**
* Stream for all notifications on all subscribed channels.
*/
def notifications(maxQueued: Int): Stream[F, Notification[String]]
}


Expand Down Expand Up @@ -413,6 +417,9 @@ object Session {
override def describeCache: Describe.Cache[F] =
proto.describeCache

override def notifications(maxQueued: Int): Stream[F, Notification[String]] =
proto.notifications(maxQueued)

}
}
}
Expand Down Expand Up @@ -470,6 +477,8 @@ object Session {

override def describeCache: Describe.Cache[G] = outer.describeCache.mapK(fk)

override def notifications(maxQueued: Int): Stream[G, Notification[String]] =
outer.notifications(maxQueued).translate(fk)
}
}

Expand Down