arthurtsang

public class DynamicServiceActivatorBeanDefinitionParser extends AbstractSingleBeanDefinitionParser {

    protected Class getBeanClass(Element element) {
        return DefaultDynamicServiceActivator.class;
    }

    @Override
    protected void doParse(Element element, BeanDefinitionBuilder bean) {
        List<Element> methodElements = DomUtils.getChildElementsByTagName(element, "method");
        ManagedMap<String, BeanDefinition> methodMetadataMap = null;

arthurtsang

FROM nextflow:19.07.0

# copy nextflow pipeline to /bfx/nextflow
ADD . /bfx/nextflow

# install git (and configure it), nginx, fcgiwrap and apache2-utils
RUN apt-get update && \
    apt-get install -y git && \
    git config --global user.email "admin@company.com" && \
    git config --global user.name "company admin"  && \

arthurtsang

# Default server configuration
# 
server {
        listen 80 default_server;
        listen [::]:80 default_server;


        root /var/www/html/git;

        # Add index.php to the list if you are using PHP

arthurtsang

#!/usr/bin/env bash

set -exuo pipefail

export PATH=$PATH:/bfx/bin/nextflow/19.07.0
spawn-fcgi -u www-data -s /var/run/fcgiwrap.socket /usr/sbin/fcgiwrap 
nginx -g "daemon on;" 
nextflow "$@"

arthurtsang

  /**
   * search for email with gmailSearchQuery (e.g. "to: someone@gmail.com subject: spam")
   * and get the raw content of the mail
   */
  async searchEmail(gmailSearchQuery: string): Promise<any[]> {
    const auth = await this.authorize();
    const gmail = google.gmail({ version: 'v1', auth });
    return new Promise((resolve, reject) => {
      gmail.users.messages.list(
        {

arthurtsang

import { browser, ElementFinder, ExpectedConditions, ProtractorBrowser, by } from 'protractor';

export const defaultTimeout = 10000;

export class AppPo {
  browserWindow: ProtractorBrowser;

  constructor(browserWindow: ProtractorBrowser = browser) {
    this.browserWindow = browserWindow;
  }

arthurtsang

import gmailCred from '../resources/gmail.credentials.json';
import { gmail_v1, google } from 'googleapis';
import * as fs from 'fs';
import { OAuth2Client } from 'google-auth-library';
import { browser, by, ElementFinder } from 'protractor';

// If modifying these scopes, delete token.json.
const SCOPES = ['https://www.googleapis.com/auth/gmail.readonly'];
// The file token.json stores the user's access and refresh tokens, and is
// created automatically when the authorization flow completes for the first

arthurtsang

private SubscribableChannel createInputChannel(String inputChannelName) {
		PublishSubscribeChannel channel = new PublishSubscribeChannel();
		channel.setBeanName(inputChannelName);
		channel.setBeanFactory(applicationContext);
		//channel.setApplySequence(true);
		((ConfigurableApplicationContext)applicationContext).getBeanFactory().registerSingleton(inputChannelName, channel);
		return channel;
	}

arthurtsang

import theano
import theano.tensor as T
from theano.sandbox.rng_mrg import MRG_RandomStreams as RandomStreams
from theano.tensor.signal.downsample import max_pool_2d
from theano.tensor.extra_ops import repeat
from theano.sandbox.cuda.dnn import dnn_conv

from time import time
import numpy as np
from matplotlib import pyplot as plt

arthurtsang

The introduction to Reactive Programming you've been missing

(by @andrestaltz)

---

This tutorial as a series of videos

If you prefer to watch video tutorials with live-coding, then check out this series I recorded with the same contents as in this article: Egghead.io - Introduction to Reactive Programming.

---