pgilad

var getSubdomain = function (baseDomain) {
    if (!baseDomain) {
        return null;
    }
    
    var regSub = new RegExp('^((?!' + baseDomain + '|www)([^.]*))', 'g');
    var _subdomain = document.location.hostname.match(regSub);
    if (_subdomain && _subdomain[0]) {
        return _subdomain[0];
    } else {

pgilad

package data;

import lombok.Getter;
import lombok.extern.slf4j.Slf4j;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
import reactor.netty.ByteBufFlux;
import reactor.netty.http.client.HttpClient;
import reactor.retry.Retry;
import settings.Settings;

pgilad

tasks.withType(AbstractArchiveTask) {
    preserveFileTimestamps = false
    reproducibleFileOrder = true
}

springBoot {
    mainClassName = 'com.blazemeter.dagger.DaggerApplication'
    buildInfo {
        properties {
             time = null

pgilad

import _ from 'lodash';
import produce from 'immer';
import { IAccount } from '../../types/account';
import { IData, IModifiable, ProduceRecipe } from '../metadata';

/**
 * An account model
 */
export class Account implements IModifiable<IAccount>, IData<IAccount> {
    readonly data: Readonly<IAccount>;

pgilad

const ts = require('typescript');
const tsConfig = require('./tsconfig.json');

const config = tsConfig.compilerOptions;

function compile(fileNames, options) {
    if (fileNames.filter(Boolean).length === 0) {
        console.log('No files');
        return;
    }

pgilad

public static final Scheduler scheduler = Schedulers.fromExecutorService(new ThreadPoolExecutor(4, 10, 60, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>()))

pgilad

<?php

class State {
  public $foo = 0;
}

class Mutator {
  public function mutateState(State $state) {
    $state->foo = 4;
  }

pgilad

FROM amazonlinux:latest

RUN yum -y update && yum install -y gcc python-devel zip which

RUN curl https://bootstrap.pypa.io/get-pip.py | python -
RUN pip install pipenv

ENV LANG en_US.UTF-8
ENV LC_ALL en_US.UTF-8
ENV SOURCE_DIR lambdas

pgilad

    public static void main(String[] args) throws InterruptedException {
        final Flux<Long> longFlux = Flux.interval(Duration.ofSeconds(1))
            .doOnSubscribe(e -> log.info("SUBSCRIBE"))
            .doOnTerminate(() -> log.info("TERMINATE"))
            .doOnComplete(() -> log.info("COMPLETE"))
            .doOnCancel(() -> log.info("CANCEL"))
            .doOnNext(s -> log.info("NEXT {}", s))
            .replay()
            .refCount(2, Duration.ofSeconds(1));

pgilad

fun digest(file: File, algorithm: String): String {
    val contents = file.readBytes()
    val messageDigest = MessageDigest.getInstance(algorithm)
    val digestBytes = messageDigest.digest(contents)

    return String.format("%032x", BigInteger(1, digestBytes)).substring(0..9)
}

project(":jetpack").configure {
    apply(plugin = "com.github.johnrengelman.shadow")