Merge pull request #2884 from jbwheatley/stream-resourceK

adds Stream.resourceK and Stream.resourceWeakK methods

core/shared/src/main/scala/fs2/Stream.scala

@@ -3672,6 +3672,12 @@ object Stream extends StreamLowPriority {
   def resource[F[_], O](r: Resource[F, O])(implicit F: MonadCancel[F, _]): Stream[F, O] =
     resourceWeak(r).scope
 
+  /** Same as [[resource]], but expressed as a FunctionK. */
+  def resourceK[F[_]](implicit F: MonadCancel[F, _]): Resource[F, *] ~> Stream[F, *] =
+    new (Resource[F, *] ~> Stream[F, *]) {
+      override def apply[A](fa: Resource[F, A]): Stream[F, A] = resource[F, A](fa)
+    }
+
   /** Like [[resource]] but does not introduce a scope, allowing finalization to occur after
     * subsequent appends or other scope-preserving transformations.
     *
@@ -3691,6 +3697,12 @@ object Stream extends StreamLowPriority {
       case Resource.Pure(o)  => Stream.emit(o)
     }
 
+  /** Same as [[resourceWeak]], but expressed as a FunctionK. */
+  def resourceWeakK[F[_]](implicit F: MonadCancel[F, _]): Resource[F, *] ~> Stream[F, *] =
+    new (Resource[F, *] ~> Stream[F, *]) {
+      override def apply[A](fa: Resource[F, A]): Stream[F, A] = resourceWeak[F, A](fa)
+    }
+
   /** Converts the supplied [[java.lang.Autoclosable]] into a singleton stream. */
   def fromAutoCloseable[F[_]: Sync, O <: AutoCloseable](fo: F[O]): Stream[F, O] =
     Stream.resource(Resource.fromAutoCloseable(fo))