@borboss the best i can come up with is to handle the exception in the lambda that would throw the exception, returning a default Id like -1 for the next part of the stream. then, use a filter() to make sure that the -1 is not emitted to the subscriber