Skip to content

Instantly share code, notes, and snippets.

@kubukoz
Last active April 2, 2021 14:24
Show Gist options
  • Save kubukoz/03039cd2fd03f252f9d5a7df4fefbc85 to your computer and use it in GitHub Desktop.
Save kubukoz/03039cd2fd03f252f9d5a7df4fefbc85 to your computer and use it in GitHub Desktop.
Return NotFound if http4s response stream is empty, wrap it in a different status otherwise
/*
Copyright 2021 Jakub Kozłowski
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
import cats.effect.MonadThrow
import cats.implicits._
import fs2.Pull
import fs2.Stream
//Example usage: onEmptyOrNonEmpty(stream)(Ok(_))(NotFound()).flatten
def onEmptyOrNonEmpty[F[_]: MonadThrow, A, B](
stream: Stream[F, A]
)(
onNonEmpty: Stream[F, A] => B
)(
onEmpty: B
)(
implicit SC: fs2.Compiler[F, F]
): F[B] = stream
.pull
.peek1
.flatMap {
_.traverse_ { case (h, t) =>
Pull.output1(onNonEmpty((Stream.emit(h) ++ t)))
}
}
.stream
.compile
.last
.map(_.getOrElse(onEmpty))
@ChristopherDavenport
Copy link

@kubukoz I'm sure people will copy this, might make sense to throw a license file up, so them doing so is alright.

@kubukoz
Copy link
Author

kubukoz commented Apr 2, 2021

Good idea, thanks :)

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment