Remove callback() from Stream and move logic inside ReactorBuilder.