RaasAhsan

use std::sync::mpsc::{sync_channel, Receiver, SyncSender};
use std::thread;

enum Message {
    Chunk(Vec<u8>),
    Flush,
}

struct TxWrite {
    tx: SyncSender<Message>,

RaasAhsan

object Lambda extends App {
  
  sealed trait Term
  sealed trait Var[I <: Index] extends Term
  sealed trait App[T1 <: Term, T2 <: Term] extends Term
  sealed trait Abs[T1 <: Term] extends Term
  sealed trait If[T1 <: Term, T2 <: Term, T3 <: Term] extends Term
  sealed trait Bool[T1 <: Boolean] extends Term

  sealed trait Index

RaasAhsan

import cats.effect._
import cats.effect.kernel.Resource
import cats.syntax.all._

trait Shared[F[_], A] {
  def resource: Resource[F, A]
}

object Shared {
  def allocate[F[_], A](resource: Resource[F, A])(implicit F: Concurrent[F]): Resource[F, (Shared[F, A], A)] = {

RaasAhsan

import cats.effect._
import org.http4s.implicits._
import org.http4s.server.blaze.BlazeServerBuilder
import org.http4s.server.middleware.Logger
import scala.concurrent.ExecutionContext.global

object BlazeServer extends IOApp {

  def server: IO[Nothing] = {
    val app = Logger.httpApp(true, true)(routes.orNotFound)

RaasAhsan

import java.util.concurrent.atomic.*;
import java.util.concurrent.*;

public class Main {
    private static ExecutorService executor = Executors.newFixedThreadPool(2);
    private static int iterations = 10000000;
  
    public static class Runner {
        // writes to canceled happen before a CAS on suspended
        // reads on canceled happen after a CAS on suspended

RaasAhsan

package tapl;

terminals true false if then else value steporvalue Bool Nat subterm succ nv

syntax

t ::= true |
      false |
      if t then t else t |
      0 |

RaasAhsan

package tapl;

terminals true false if then else value steporvalue Bool

syntax

t ::= true |
      false |
      if t then t else t

RaasAhsan

[info] running org.simpleapp.example.Example 
1
2
3
4
5
IOTrace: 13 frames captured, 0 omitted
╭ flatMap
│ ╰╮

RaasAhsan

IOTrace: 0 omitted frames
╭ flatMap
│ ╰╮
│  ├ org.simpleapp.example.Example.main (Example.scala:21)
│  ├ org.simpleapp.example.Example.main (Example.scala:-1)
│  ├ sun.reflect.NativeMethodAccessorImpl.invoke0 (NativeMethodAccessorImpl.java:-2)
│  ├ sun.reflect.NativeMethodAccessorImpl.invoke (NativeMethodAccessorImpl.java:62)
│  ├ sun.reflect.DelegatingMethodAccessorImpl.invoke (DelegatingMethodAccessorImpl.java:43)
│  ├ java.lang.reflect.Method.invoke (Method.java:498)

RaasAhsan

Useful FFMPEG commands

Print out GOP picture types

$ ffprobe -v quiet -print_format json -i vods/1/low/segment-0.ts -show_frames | \
    jq -r '.frames[] | select(.media_type=="video") | .pict_type' | \
    tr -d '\n'
IBBBPPBPBPBPBPBPBBPBBBPBBBPBBPBBBPBBBPBPBBBPBBBPIBBPBBBPBBBPBBBPBBBPBBBPBBBPBBBPBBBPBBBPBBBPBBBPIBBBPBBBPBBBPBBBPBBBPBBBPBBBPBBBPBBBPBBBPBBBPBBPIBBBPBBBPBBBPBBBPBBBPBBBPBBBPBBBPBBBPBBBPBBBPBBPIBBBPBBBPBBBPBBBPBBPBBBPBBBPBBBPBBBPBPBBBPBBBPBP