JurajBegovac

MIT License

Copyright (c) 2022-2023 Juraj Begovac

Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"), to deal
in the Software without restriction, including without limitation the rights
to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
copies of the Software, and to permit persons to whom the Software is
furnished to do so, subject to the following conditions:

klaftertief

• Star this gist to see the talk at ReactiveConf 2016.
• Retweet to spread the word.
• Have a look at this blog post to see other proposals.
• Try elm-search to see what this is all about.

---

An API search engine in Elm for Elm

Elm is a statically typed functional language that compiles to JavaScript. It's well-known for its developer experience: the compiler provides nice error messages, the package system enforces semantic versioning for all published packages and makes sure every exposed value or type has some documentation and type annotations.

junegunn

# GIT heart FZF
# -------------

is_in_git_repo() {
  git rev-parse HEAD > /dev/null 2>&1
}

fzf-down() {
  fzf --height 50% --min-height 20 --border --bind ctrl-/:toggle-preview "$@"
}

dlew

public static Action1<Throwable> crashOnError() {
    final Throwable checkpoint = new Throwable();
    return throwable -> {
        StackTraceElement[] stackTrace = checkpoint.getStackTrace();
        StackTraceElement element = stackTrace[1]; // First element after `crashOnError()`
        String msg = String.format("onError() crash from subscribe() in %s.%s(%s:%s)",
            element.getClassName(),
            element.getMethodName(),
            element.getFileName(),
            element.getLineNumber());

NiteshKant

import rx.Observable;

public class Pager {

    public static void main(String[] args) {
        Observable.range(1, 1000)
                  .window(10)
                  .doOnNext(nextBatch -> System.out.println("Next page."))
                  .flatMap(nums -> nums, 1)
                  .forEach(System.out::println);

mttkay

public class Pager<I, O> {

    private static final Observable FINISH_SEQUENCE = Observable.never();

    private PublishSubject<Observable<I>> pages;
    private Observable<I> nextPage = finish();
    private Subscription subscription = Subscriptions.empty();

    private final PagingFunction<I> pagingFunction;
    private final Func1<I, O> pageTransformer;

artem-zinnatullin

// You can place it in the root build.gradle

allprojects {
  tasks.withType(JavaForkOptions) {
    // Forked processes like GradleWorkerMain for tests won't steal focus!
    jvmArgs '-Djava.awt.headless=true'
  }
}

evelyne24

import org.junit.Test;
import org.junit.runner.RunWith;
import org.junit.runners.JUnit4;

import java.util.Arrays;
import java.util.Collections;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicLong;

adewes

To use this bot:

• Download ads_bot.py and requirements.txt.
• Type pip install -r requirements.txt to install the requirements.
• Fill out the required information in the Python file.
• Ideally, create a (free) Slack account and set up a web hook to receive notifications from the bot.
• Run the script :)
• Relax and be ready to answer incoming calls :D

benjchristensen

import java.util.List;
import java.util.concurrent.TimeUnit;

import rx.Observable;
import rx.Subscriber;
import rx.schedulers.Schedulers;

public class DebounceBuffer {

    public static void main(String args[]) {