Refactoring Composable Streams in RxJS by John Lindquist