ajaychandran

import com.raquo.laminar.api.L._
import org.scalajs.dom

import scala.scalajs.js

/** @see [[https://www.websocket.org/echo.html]] */
object WebSocketTester {

  private val url       = "wss://echo.websocket.org/"
  private val transmit  = Var("hello")

ajaychandran

// Perform HTTP requests lazily (onStart) as opposed to EventStream.fromFuture(dom.Ajax.*)
final class AjaxEventStream(
  method: String,
  url: String,
  data: dom.ext.Ajax.InputData,
  timeout: Int,
  headers: Map[String, String],
  withCredentials: Boolean,
  responseType: String
) extends EventStream[dom.XMLHttpRequest] {

ajaychandran

package zio

import java.io.{ InputStream, OutputStream }
import java.nio.charset.StandardCharsets

object streaming {

  type Pull[-R, +E, +I]     = ZIO[R, Option[E], I]
  type Push[-R, +E, -I]     = I => ZIO[R, E, Unit]
  type Step[-R, +E, -I, +O] = I => ZIO[R, E, O]

ajaychandran

  // Available variables:
  // - Machine
  // - interpret
  // - assign
  // - send
  // - sendParent
  // - spawn
  // - raise
  // - actions

ajaychandran

package gdx;

import com.badlogic.gdx.ApplicationAdapter;
import com.badlogic.gdx.Gdx;
import com.badlogic.gdx.backends.lwjgl3.*;

import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

ajaychandran

final class FinalizerCancelable(finalizer: () => Unit) extends BooleanCancelable {
  private val state = new AtomicReference(FinalizerCancelable.State())

  def isCanceled: Boolean = state.get().canceled

  def acquire(): BooleanCancelable = {
    state.get() match {
      case FinalizerCancelable.State(true, _) => BooleanCancelable.alreadyCanceled
      case s => state.compareAndSet(s, s.copy(active = s.active + 1)) match {
        case false => acquire()

ajaychandran

package scodec.codecs

import scala.language.higherKinds

import scodec._
import scodec.bits.BitVector

object DelimitedCodec {

  /**

ajaychandran

package scodec.codecs

import scodec._
import scodec.bits.{ByteVector, BitVector}

/**
 * ChecksumCodec
 */
object ChecksumCodec {