mirror of
https://github.com/TheAnachronism/docspell.git
synced 2025-06-21 18:08:25 +00:00
Update fs2 to 2.3.0
This commit is contained in:
@ -26,7 +26,7 @@ object Conversion {
|
||||
blocker: Blocker,
|
||||
logger: Logger[F]
|
||||
): Resource[F, Conversion[F]] =
|
||||
Resource.pure(new Conversion[F] {
|
||||
Resource.pure[F, Conversion[F]](new Conversion[F] {
|
||||
|
||||
def toPDF[A](dataType: DataType, lang: Language, handler: Handler[F, A])(
|
||||
in: Stream[F, Byte]
|
||||
|
@ -19,7 +19,7 @@ object ONode {
|
||||
private[this] val logger = getLogger
|
||||
|
||||
def apply[F[_]: Effect](store: Store[F]): Resource[F, ONode[F]] =
|
||||
Resource.pure(new ONode[F] {
|
||||
Resource.pure[F, ONode[F]](new ONode[F] {
|
||||
|
||||
def register(appId: Ident, nodeType: NodeType, uri: LenientUri): F[Unit] =
|
||||
for {
|
||||
|
@ -22,7 +22,7 @@ object JobQueue {
|
||||
private[this] val logger = getLogger
|
||||
|
||||
def apply[F[_]: Effect](store: Store[F]): Resource[F, JobQueue[F]] =
|
||||
Resource.pure(new JobQueue[F] {
|
||||
Resource.pure[F, JobQueue[F]](new JobQueue[F] {
|
||||
|
||||
def nextJob(
|
||||
prio: Ident => F[Priority],
|
||||
|
Reference in New Issue
Block a user