| package single_routine | |
| import ( | |
| "log" | |
| "sync" | |
| "sync/atomic" | |
| ) | |
| type deferred[B any] struct { | |
| b B |
| export const ws = webSocket<WebsocketMessage>(`wss://${location.hostname}:${location.protocol === 'https:' ? 443 : 80}/ws/`); | |
| export const wsObserver = ws | |
| .pipe( | |
| retryWhen(errors => | |
| errors.pipe( | |
| delay(1000) | |
| ) | |
| ) | |
| ); |
| import cats.effect._ | |
| import cats.effect.concurrent.{Ref, Semaphore} | |
| import cats.implicits._ | |
| trait SerialRef[F[_], A] { | |
| def get: F[A] | |
| def modify[B](f: A => F[(A, B)]): F[B] |
| /* | |
| scalaVersion := "2.12.7" | |
| resolvers += Resolver.sonatypeRepo("snapshots") | |
| libraryDependencies += "co.fs2" %% "fs2-core" % "1.0.1-SNAPSHOT" | |
| */ | |
| import cats._ | |
| import cats.implicits._ | |
| import cats.effect._ |
| import cats.effect._ | |
| import cats.effect.implicits._ | |
| import cats.effect.concurrent._ | |
| import cats.implicits._ | |
| import cats._ | |
| import cats.temp.par._ | |
| object ConcurrentSuccess{ | |
| def parAttempt[G[_]: Traverse, F[_]: Par: MonadError[?[_], Throwable], A](xs: G[F[A]]): F[G[Either[Throwable, A]]] = |
| // fs2 1.0.0 | |
| import cats.effect._ | |
| import cats.effect.concurrent._ | |
| import cats.implicits._ | |
| import fs2._ | |
| import fs2.concurrent._ | |
| import scala.concurrent.duration._ | |
| object Main extends IOApp { |
I have some data which has adjacent entries that I want to group together and perform actions on.
I know roughly that fs2.Pull can be used to "step" through a stream and do more complicated
logic than the built in combinators allow. I don't know how to write one though!
In the end we should have something like
def combineAdjacent[F[_], A](
shouldCombine: (A, A) => Boolean,
| <!DOCTYPE html> | |
| <html> | |
| <head> | |
| <title>Fireside Chat</title> | |
| <link rel="stylesheet" href="/style/style.css"> | |
| </head> | |
| <body> | |
| <h1>Fireside Chat</h1> | |
| <div id="app"> | |
| <div v-if="state == 0"> |
| package example.playground | |
| import java.io.InputStream | |
| import cats.effect.IO | |
| import fs2._ | |
| import cats.implicits._ | |
| import java.util.concurrent.ScheduledExecutorService | |
| import scala.concurrent.duration.FiniteDuration |
| package bannobankapp; | |
| import java.util.HashMap; | |
| import java.util.Map; | |
| import java.util.Scanner; | |
| public class Bank { | |
| public String bankName; | |
| Map<String, User> userMap = new HashMap<String, User>(); |
