Theres an extra wrapping of Publishers with the old Observable classes. Now the Scala driver wraps the reactive streams driver - there isn't a need for this extra object / layer.