Exception returning UnicastSubject Observable from flow

Description

*To Reproduce*

Create the following flow:
` @StartableByRPC
class ObservableSubject(val unicast: Boolean) : FlowLogic<rx.Observable<Int>>() {
override fun call(): rx.Observable<Int> {
val o: rx.Observable<Int> = if (unicast) UnicastSubject.create() else PublishSubject.create()
return o
}
}`

And the following driver test:
` @Test
fun unicastSujectTest() = driver(driverParameters) {
val handle = startNode().getOrThrow()
val observable = handle.rpc.startFlow(DataFeedFlow::ObservableSubject, *true*).returnValue.get()
observable.subscribe().unsubscribe()
println("string: $observable")
}`

When the test is with unicast=false the test completes without failure.
When run with unicast=true (as above) the test fails with the stack trace below

Created by github action.

Assignee

Unassigned

Reporter

eng.bot

Labels

Sprint

None

Epic Link

None

Priority

Medium

Engineering Teams

Kernel

Fix versions

Story Points / Dev Days

0

Ported to...

None
Configure