text:
using org.xmlvm;
namespace java.util {
public abstract class TimerTask: global::java.lang.Object,global::java.lang.Runnable {
public global::java.lang.Object _flock;

public bool _fcancelled;

public long _fwhen;

public long _fperiod;

public bool _ffixedRate;

private long _fscheduledTime;

public virtual long getWhen(){
//XMLVM_BEGIN_WRAPPER[java.util.TimerTask: long getWhen()]
    global::System.Object _r0_o = null;
    global::org.xmlvm._nElement _r1;
    global::System.Object _r1_o = null;
    global::System.Object _r3_o = null;
    global::org.xmlvm._nExceptionAdapter _ex = null;
    _r3_o = this;
    _r0_o = ((global::java.util.TimerTask) _r3_o)._flock;
    global::System.Threading.Monitor.Enter(_r0_o);
    try {
    _r1.l = ((global::java.util.TimerTask) _r3_o)._fwhen;
    global::System.Threading.Monitor.Exit(_r0_o);
    return _r1.l;
    }
    catch (global::System.Exception e) {
 global::org.xmlvm._nExceptionAdapter ex = e as global::org.xmlvm._nExceptionAdapter ?? new global::org.xmlvm._nExceptionAdapter(e.ToString(), e.ToJavaException());
        global::System.Object _java_exception = ex.getJavaException();
        if (_java_exception is global::java.lang.Object) {
            _ex = ex;
            goto label7;
        }
        throw ex;
    } // end catch
    label7:;
    try {
    _r1_o = _ex.getJavaException();
    _ex = null;
    global::System.Threading.Monitor.Exit(_r0_o);
    }
    catch (global::System.Exception e) {
 global::org.xmlvm._nExceptionAdapter ex = e as global::org.xmlvm._nExceptionAdapter ?? new global::org.xmlvm._nExceptionAdapter(e.ToString(), e.ToJavaException());
        global::System.Object _java_exception = ex.getJavaException();
        if (_java_exception is global::java.lang.Object) {
            _ex = ex;
            goto label7;
        }
        throw ex;
    } // end catch
    throw new global::org.xmlvm._nExceptionAdapter((global::System.Object) _r1_o);
//XMLVM_END_WRAPPER[java.util.TimerTask: long getWhen()]
}

public virtual void setScheduledTime(long n1){
//XMLVM_BEGIN_WRAPPER[java.util.TimerTask: void setScheduledTime(long)]
    global::System.Object _r0_o = null;
    global::System.Object _r1_o = null;
    global::System.Object _r2_o = null;
    global::org.xmlvm._nElement _r3;
    global::org.xmlvm._nExceptionAdapter _ex = null;
    _r2_o = this;
    _r3.l = n1;
    _r0_o = ((global::java.util.TimerTask) _r2_o)._flock;
    global::System.Threading.Monitor.Enter(_r0_o);
    try {
    ((global::java.util.TimerTask) _r2_o)._fscheduledTime = _r3.l;
    global::System.Threading.Monitor.Exit(_r0_o);
    return;
    }
    catch (global::System.Exception e) {
 global::org.xmlvm._nExceptionAdapter ex = e as global::org.xmlvm._nExceptionAdapter ?? new global::org.xmlvm._nExceptionAdapter(e.ToString(), e.ToJavaException());
        global::System.Object _java_exception = ex.getJavaException();
        if (_java_exception is global::java.lang.Object) {
            _ex = ex;
            goto label7;
        }
        throw ex;
    } // end catch
    label7:;
    try {
    _r1_o = _ex.getJavaException();
    _ex = null;
    global::System.Threading.Monitor.Exit(_r0_o);
    }
    catch (global::System.Exception e) {
 global::org.xmlvm._nExceptionAdapter ex = e as global::org.xmlvm._nExceptionAdapter ?? new global::org.xmlvm._nExceptionAdapter(e.ToString(), e.ToJavaException());
        global::System.Object _java_exception = ex.getJavaException();
        if (_java_exception is global::java.lang.Object) {
            _ex = ex;
            goto label7;
        }
        throw ex;
    } // end catch
    throw new global::org.xmlvm._nExceptionAdapter((global::System.Object) _r1_o);
//XMLVM_END_WRAPPER[java.util.TimerTask: void setScheduledTime(long)]
}

public virtual bool isScheduled(){
//XMLVM_BEGIN_WRAPPER[java.util.TimerTask: boolean isScheduled()]
    global::System.Object _r0_o = null;
    global::org.xmlvm._nElement _r1;
    global::System.Object _r1_o = null;
    global::org.xmlvm._nElement _r3;
    global::System.Object _r5_o = null;
    global::org.xmlvm._nExceptionAdapter _ex = null;
    _r5_o = this;
    _r3.l = 0L;
    _r0_o = ((global::java.util.TimerTask) _r5_o)._flock;
    global::System.Threading.Monitor.Enter(_r0_o);
    try {
    _r1.l = ((global::java.util.TimerTask) _r5_o)._fwhen;
    _r1.i = _r1.l > _r3.l ? 1 : (_r1.l == _r3.l ? 0 : -1);
    if (_r1.i > 0) goto label20;
    _r1.l = ((global::java.util.TimerTask) _r5_o)._fscheduledTime;
    _r1.i = _r1.l > _r3.l ? 1 : (_r1.l == _r3.l ? 0 : -1);
    if (_r1.i > 0) goto label20;
    _r1.i = 0;
    }
    catch (global::System.Exception e) {
 global::org.xmlvm._nExceptionAdapter ex = e as global::org.xmlvm._nExceptionAdapter ?? new global::org.xmlvm._nExceptionAdapter(e.ToString(), e.ToJavaException());
        global::System.Object _java_exception = ex.getJavaException();
        if (_java_exception is global::java.lang.Object) {
            _ex = ex;
            goto label22;
        }
        throw ex;
    } // end catch
    label18:;
    try {
    global::System.Threading.Monitor.Exit(_r0_o);
    return _r1.i!=0;
    }
    catch (global::System.Exception e) {
 global::org.xmlvm._nExceptionAdapter ex = e as global::org.xmlvm._nExceptionAdapter ?? new global::org.xmlvm._nExceptionAdapter(e.ToString(), e.ToJavaException());
        global::System.Object _java_exception = ex.getJavaException();
        if (_java_exception is global::java.lang.Object) {
            _ex = ex;
            goto label22;
        }
        throw ex;
    } // end catch
    label20:;
    try {
    _r1.i = 1;
    goto label18;
    }
    catch (global::System.Exception e) {
 global::org.xmlvm._nExceptionAdapter ex = e as global::org.xmlvm._nExceptionAdapter ?? new global::org.xmlvm._nExceptionAdapter(e.ToString(), e.ToJavaException());
        global::System.Object _java_exception = ex.getJavaException();
        if (_java_exception is global::java.lang.Object) {
            _ex = ex;
            goto label22;
        }
        throw ex;
    } // end catch
    label22:;
    try {
    _r1_o = _ex.getJavaException();
    _ex = null;
    global::System.Threading.Monitor.Exit(_r0_o);
    }
    catch (global::System.Exception e) {
 global::org.xmlvm._nExceptionAdapter ex = e as global::org.xmlvm._nExceptionAdapter ?? new global::org.xmlvm._nExceptionAdapter(e.ToString(), e.ToJavaException());
        global::System.Object _java_exception = ex.getJavaException();
        if (_java_exception is global::java.lang.Object) {
            _ex = ex;
            goto label22;
        }
        throw ex;
    } // end catch
    throw new global::org.xmlvm._nExceptionAdapter((global::System.Object) _r1_o);
//XMLVM_END_WRAPPER[java.util.TimerTask: boolean isScheduled()]
}

new public void @this(){
//XMLVM_BEGIN_WRAPPER[java.util.TimerTask: void <init>()]
    global::System.Object _r0_o = null;
    global::System.Object _r1_o = null;
    _r1_o = this;
    ((global::java.lang.Object) _r1_o).@this();
    _r0_o = new global::java.lang.Object();
    ((global::java.lang.Object) _r0_o).@this();
    ((global::java.util.TimerTask) _r1_o)._flock = (global::java.lang.Object) _r0_o;
    return;
//XMLVM_END_WRAPPER[java.util.TimerTask: void <init>()]
}

public virtual bool cancel(){
//XMLVM_BEGIN_WRAPPER[java.util.TimerTask: boolean cancel()]
    global::System.Object _r0_o = null;
    global::org.xmlvm._nElement _r1;
    global::System.Object _r1_o = null;
    global::org.xmlvm._nElement _r2;
    global::org.xmlvm._nElement _r3;
    global::org.xmlvm._nElement _r5;
    global::System.Object _r6_o = null;
    global::org.xmlvm._nExceptionAdapter _ex = null;
    _r6_o = this;
    _r5.i = 1;
    _r0_o = ((global::java.util.TimerTask) _r6_o)._flock;
    global::System.Threading.Monitor.Enter(_r0_o);
    try {
    _r1.i = ((global::java.util.TimerTask) _r6_o)._fcancelled ? 1 : 0;
    if (_r1.i != 0) goto label22;
    _r1.l = ((global::java.util.TimerTask) _r6_o)._fwhen;
    _r3.l = 0L;
    _r1.i = _r1.l > _r3.l ? 1 : (_r1.l == _r3.l ? 0 : -1);
    if (_r1.i <= 0) goto label22;
    _r1.i = _r5.i;
    }
    catch (global::System.Exception e) {
 global::org.xmlvm._nExceptionAdapter ex = e as global::org.xmlvm._nExceptionAdapter ?? new global::org.xmlvm._nExceptionAdapter(e.ToString(), e.ToJavaException());
        global::System.Object _java_exception = ex.getJavaException();
        if (_java_exception is global::java.lang.Object) {
            _ex = ex;
            goto label24;
        }
        throw ex;
    } // end catch
    label17:;
    try {
    _r2.i = 1;
    ((global::java.util.TimerTask) _r6_o)._fcancelled = 0!=_r2.i;
    global::System.Threading.Monitor.Exit(_r0_o);
    return _r1.i!=0;
    }
    catch (global::System.Exception e) {
 global::org.xmlvm._nExceptionAdapter ex = e as global::org.xmlvm._nExceptionAdapter ?? new global::org.xmlvm._nExceptionAdapter(e.ToString(), e.ToJavaException());
        global::System.Object _java_exception = ex.getJavaException();
        if (_java_exception is global::java.lang.Object) {
            _ex = ex;
            goto label24;
        }
        throw ex;
    } // end catch
    label22:;
    try {
    _r1.i = 0;
    goto label17;
    }
    catch (global::System.Exception e) {
 global::org.xmlvm._nExceptionAdapter ex = e as global::org.xmlvm._nExceptionAdapter ?? new global::org.xmlvm._nExceptionAdapter(e.ToString(), e.ToJavaException());
        global::System.Object _java_exception = ex.getJavaException();
        if (_java_exception is global::java.lang.Object) {
            _ex = ex;
            goto label24;
        }
        throw ex;
    } // end catch
    label24:;
    try {
    _r1_o = _ex.getJavaException();
    _ex = null;
    global::System.Threading.Monitor.Exit(_r0_o);
    }
    catch (global::System.Exception e) {
 global::org.xmlvm._nExceptionAdapter ex = e as global::org.xmlvm._nExceptionAdapter ?? new global::org.xmlvm._nExceptionAdapter(e.ToString(), e.ToJavaException());
        global::System.Object _java_exception = ex.getJavaException();
        if (_java_exception is global::java.lang.Object) {
            _ex = ex;
            goto label24;
        }
        throw ex;
    } // end catch
    throw new global::org.xmlvm._nExceptionAdapter((global::System.Object) _r1_o);
//XMLVM_END_WRAPPER[java.util.TimerTask: boolean cancel()]
}

public virtual long scheduledExecutionTime(){
//XMLVM_BEGIN_WRAPPER[java.util.TimerTask: long scheduledExecutionTime()]
    global::System.Object _r0_o = null;
    global::org.xmlvm._nElement _r1;
    global::System.Object _r1_o = null;
    global::System.Object _r3_o = null;
    global::org.xmlvm._nExceptionAdapter _ex = null;
    _r3_o = this;
    _r0_o = ((global::java.util.TimerTask) _r3_o)._flock;
    global::System.Threading.Monitor.Enter(_r0_o);
    try {
    _r1.l = ((global::java.util.TimerTask) _r3_o)._fscheduledTime;
    global::System.Threading.Monitor.Exit(_r0_o);
    return _r1.l;
    }
    catch (global::System.Exception e) {
 global::org.xmlvm._nExceptionAdapter ex = e as global::org.xmlvm._nExceptionAdapter ?? new global::org.xmlvm._nExceptionAdapter(e.ToString(), e.ToJavaException());
        global::System.Object _java_exception = ex.getJavaException();
        if (_java_exception is global::java.lang.Object) {
            _ex = ex;
            goto label7;
        }
        throw ex;
    } // end catch
    label7:;
    try {
    _r1_o = _ex.getJavaException();
    _ex = null;
    global::System.Threading.Monitor.Exit(_r0_o);
    }
    catch (global::System.Exception e) {
 global::org.xmlvm._nExceptionAdapter ex = e as global::org.xmlvm._nExceptionAdapter ?? new global::org.xmlvm._nExceptionAdapter(e.ToString(), e.ToJavaException());
        global::System.Object _java_exception = ex.getJavaException();
        if (_java_exception is global::java.lang.Object) {
            _ex = ex;
            goto label7;
        }
        throw ex;
    } // end catch
    throw new global::org.xmlvm._nExceptionAdapter((global::System.Object) _r1_o);
//XMLVM_END_WRAPPER[java.util.TimerTask: long scheduledExecutionTime()]
}

public abstract void run();

//XMLVM_BEGIN_WRAPPER[java.util.TimerTask]
//XMLVM_END_WRAPPER[java.util.TimerTask]

} // end of class: TimerTask

} // end of namespace: java.util

redpajama_set_name: RedPajamaGithub


text:
namespace TMC {

LockedBlockException::LockedBlockException(Vec3i lockedPos)
    : SceneException(lockedPos){
}

const char *LockedBlockException::what() const noexcept {
    return ("Trying to perform operation on locked block: " + m_pos.toString() + ".").c_str();
}

}


text:
$(document).ready(function() {
		$("#form").submit(function() {
			if(validation()){
				$('#loader-login').show();
				$("button[type='submit']").attr("disabled","disabled");
				updateEquipment($(this).serialize());
			}
		});
		$("#type").change(function() {
			if ($("#brand").val() != "") {
				$("#loader-model").show();
				searchModels($(this).val(), $("#brand").val());
			}
		});
		$("#brand").change(function() {
			if ($("#type").val() != "") {
				$("#loader-model").show();
				searchModels($("#type").val(), $(this).val());
			}
		});
		$("#serial").change(function() {
			searchSerial($(this).val());
		});
		$("#mac").change(function() {
			if($(this).val().length > 0){
				macAddress($(this).val(), $(this));
			}
		}).keyup(function(key){
			if($(this).val().length <= 17){
				var character = $(this).val().slice(-1);
				if(!character.match(/[0-9A-Fa-f]/)){
					var string = $(this).val();
					$(this).val(string.substring(0, string.length - 1));
				}
				macAddress($(this).val(), $(this));
			}else if($(this).val().length == 0){
			}else{
				var string = $(this).val();
				$(this).val(string.substring(0, string.length - 1));
			}
		});
	});
	function searchModels(type, brand) {
		$("#model").html("<option value=''>Choose..</option>");
		var data = "type=" + type + "&brand=" + brand;
		$.post(addressSearchModels, data, function(send) {
			if (send.state) {
				if (send.type != '') {
					showMessage(send.type);
					$("#loader-model").fadeOut('fast');
				} else {
					loadElement($("#model"), send.models);
					$("#loader-model").fadeOut('fast');
				}
			}
		}, 'JSON');
	}
	function searchSerial(serial) {
		var data = "serial=" + serial + "&id=" + $("#id").val();
		$.post(addressSearchSerial, data, function(send) {
			if (send.state) {
				$("#serial").removeClass("error");
			} else {
				$("#serial").addClass("error");
				showMessage(79);
			}
		}, 'JSON');
	}
	function searchMac(mac) {
		var data = "mac=" + mac + "&id=" + $("#id").val();
		$.post(addressSearchMac, data, function(send) {
			if (send.state) {
				$("#mac").removeClass("error");
			} else {
				$("#mac").addClass("error");
				showMessage(81);
			}
		}, 'JSON');
	}
	function updateEquipment(form) {
		var data = form;
		$.post(addressUpdateEquipment, data, function(send) {
			if (send.state) {
				$("#loader-login").fadeOut('fast');
				showMessage(send.type);
				$("button[type='submit']").removeAttr("disabled");
			}
		}, 'JSON');
	}
	function validation(){
		if($("#serial").hasClass('error')||($('#mac').hasClass('error'))){
			return false;
		}
		return true;
	}
	function macAddress(string, input){
		var newString = '';
		for(var i=0; i < string.length; i++){
			if(i > 16 || newString.length > 16 ){
				break;
			}
			if(newString.length == 2 || newString.length == 5 || newString.length == 8 || newString.length == 11 || newString.length == 14 ){
				if(string[i] != "-"){
					newString = newString + '-';
				}
			}
			newString = newString + string[i];
		}
		input.val(newString.toUpperCase());
		searchMac(newString.toUpperCase());
	}


text:
<?php

namespace Refinery29\Sitemap\Test\Unit\Component;

use Refinery29\Sitemap\Component\UrlSetInterface;
use Refinery29\Test\Util\TestHelper;

final class UrlSetInterfaceTest extends \PHPUnit_Framework_TestCase
{
    use TestHelper;

    public function testConstants()
    {
        $this->assertSame('xmlns', UrlSetInterface::XML_NAMESPACE_ATTRIBUTE);
        $this->assertSame('http://www.sitemaps.org/schemas/sitemap/0.9', UrlSetInterface::XML_NAMESPACE_URI);

        $this->assertSame(50000, UrlSetInterface::URL_MAX_COUNT);
    }
}


text:
#ifndef __APPS_INCLUDE_SYSTEM_UTILS_H
#define __APPS_INCLUDE_SYSTEM_UTILS_H
#include <tinyara/config.h>

#ifdef CONFIG_SYSTEM_CMDS
void system_register_utilcmds(void);
#endif
#ifdef CONFIG_FS_CMDS
void fs_register_utilcmds(void);
#endif
#ifdef CONFIG_NET_CMDS
void net_register_utilcmds(void);
void net_register_appcmds(void);
#endif

#ifdef CONFIG_ENABLE_STACKMONITOR_CMD
void stkmon_logging(struct tcb_s *);
#endif

#if defined(CONFIG_ENABLE_CPULOAD)
int utils_cpuload(int argc, char **args);
#endif

#if defined(CONFIG_ENABLE_DATE)
int utils_date(int argc, char **args);
#endif

#if defined(CONFIG_ENABLE_DMESG)
int utils_dmesg(int argc, char **args);
#endif

#if defined(CONFIG_ENABLE_ENV_GET)
int utils_env_get(int argc, char **args);
#endif

#if defined(CONFIG_ENABLE_ENV_SET)
int utils_env_set(int argc, char **args);
#endif

#if defined(CONFIG_ENABLE_ENV_UNSET)
int utils_env_unset(int argc, char **args);
#endif

#if defined(CONFIG_ENABLE_FREE)
int utils_free(int argc, char **args);
#endif

#if defined(CONFIG_ENABLE_HEAPINFO)
int utils_heapinfo(int argc, char **args);
#endif

#if defined(CONFIG_ENABLE_PRODCONFIG)
int utils_prodconfig(int argc, char **args);
#endif

#if defined(CONFIG_ENABLE_IRQINFO)
int utils_irqinfo(int argc, char **args);
#endif

#if defined(CONFIG_ENABLE_KILL)
int utils_kill(int argc, char **args);
#endif

#if defined(CONFIG_ENABLE_KILLALL)
int utils_killall(int argc, char **args);
#endif

#if defined(CONFIG_ENABLE_PS)
int utils_ps(int argc, char **args);
#endif

#if defined(CONFIG_ENABLE_STACKMONITOR)
int utils_stackmonitor(int argc, char **args);
#endif

#if defined(CONFIG_TTRACE)
int utils_ttrace(int argc, char **args);
#endif

#if defined(CONFIG_ENABLE_TZSELECT)
int utils_tzselect(int argc, char **args);
#endif

#if defined(CONFIG_ENABLE_UPTIME)
int utils_uptime(int argc, char **args);
#endif

#endif							/* __APPS_INCLUDE_SYSTEM_UTILS_H */


text:
ballpark.js
====================

ballpark.js is an in-browser app that gives you a ballpark estimate of how long a commonly used web asset takes to load. Given a queue of HTML files, ballpark.js loads each file into an iframe and logs the relevant Navigation Timing API values when these are set. When the queue is emptied, the user is presented with a table of results.

Once a testrun is completed, the results are stored in the location.hash property in serialized JSON format. Like [SunSpider](http://www.webkit.org/perf/sunspider/sunspider.html), ballpark.js will recognize a hashed url, and render the corresponding results when the onload event occurs. This way, a URL with results can be passed around for verification and comparison.

Ballpark.js is MIT-licensed, see LICENSE.txt.

## How are the results computed?

The result is arrived at by calculating performance.loadEventEnd - performance.requestStart. This determines the time (in ms) from the browser starts requesting resources from the server (after DNS has been resolved) to the moment the load event finishes.

## How do I run the tests?

After setting up the project on your webserver with correct .htaccess-settings and so forth (se below), point your webbrowser to the root-directory. The tests run in-browser - click 'engage' and you should be all set!

## How do I add my own tests?

1. Create a folder with all the assets you want, and an index.html that loads them.
2. If there is already a category in /tests/ matching the content of your test, place your testfolder there. If not, create a new folder in /tests/ named after the category in question, and place your testfolder in this newly created folder.
3. Update the TESTRUNNER.data object found in tests.js. The object has a property for each category, containing an array of tests. So if you have created, say, a test combining such-and-such images, add the title of your test to the images-category:

```javascript
...
    TESTRUNNER.data = {
        ...
        images: ["avatars", "1136-pixel-image","2880-pixel-image", "my_new_test"],
        ...
    }
```

## Deploying ballpark.js on an Apache-server

We want Apache to send no-cache headers back to the client. Therefore, the project contains an .htaccess file that sets these headers. At this time we only have configuration details for Apache, not nginx or other systems.

### Permitting directory-level configurations via .htaccess files

If you are unfamilliar with .htaccess-files, consult the [offical documentation](http://httpd.apache.org/docs/current/howto/htaccess.html).

Here is a crude heuristic tested on Debian 7.

1. With root privileges, edit /etc/apache2/sites-available/default
2. Set

```
    <Directory /var/www/>
    ...
    AllowOverride All
```
3. Test your configuration by writing gibberish in the .htaccess-file. This should trigger a 500 internal server error when accessing the project root folder from a browser.

## Roadmap

In the future, we want

* A deployment script that automatically creates TESTRUNNER.data from the directory structure in /tests.
* Enable the user to cherry-pick which tests are run via a checkbox in the browser, and let the user decide the number of iterations per test.


text:
[![](http://img.shields.io/github/issues/neoclide/vim-jsx-improve.svg)](https://github.com/neoclide/vim-jsx-improve/issues)
[![](http://img.shields.io/badge/license-MIT-blue.svg)](LICENSE)

Makes your javascript files support React jsx correctly.

Javascript syntax from [pangloss/vim-javascript](https://github.com/pangloss/vim-javascript)

Jsx highlight and indent code changed from [MaxMEllon/vim-jsx-pretty](https://github.com/MaxMEllon/vim-jsx-pretty)

- Fixed syntax highlighting and indentation for React jsx files.
- Works well with xml.vim

This plugin have no dependency, all the code you need for jsx and javascript is
included.

**Note:** you need to disable **vim-javascript** plugin if have installed, I have to
change some highlight group to make it works with jsx.

### Installation

Use pathogen or vundle is recommended. Vundle:

    Plugin 'chemzqm/vim-jsx-improve'

This plugin support `javascriptreact` filetype which is introduced on newer
version of vim8 and neovim.

Use `let g:jsx_improve_javascriptreact = 0` to disable javascriptreact support.

### Quick jump to function braces

You can use `[[` `]]` `[]` `][` to quick jump to `{` `}` position of functions, set `g:jsx_improve_motion_disable` to `1` to disable it.
### New Syntax group
this is a new syntax group .if you want highlight it ,your colorscheme should  add `jsxEndComponentName` color.

|name|place|
|---|---|
|jsxEndComponentName| `</Capitals>`<br />`__~~~~~~~~_` |
### GIF

![2016-12-10 01_27_59](https://cloud.githubusercontent.com/assets/251450/21058283/26d3b946-be78-11e6-8b1e-78e146ec3496.gif)

The colorscheme is [gruvbox](https://github.com/morhetz/gruvbox)

The keystroke visualizer is [keycastr](https://github.com/sdeken/keycastr)

### Feed back welcome

Feel free to open a ticket if your have problem with this plugin.


text:
<?php

/**
 * Created by PhpStorm.
 * User: Administrator
 * Date: 2018/7/25
 * Time: 13:40
 */
class Book implements BookInterface
{
    private $page;

    public function open()
    {
        $this->page = 1;
        // TODO: Implement open() method.
    }

    public function getPage()
    {
        return $this->page;
        // TODO: Implement getPage() method.
    }

    public function turnPage()
    {
        $this->page ++;
        // TODO: Implement turnPage() method.
    }
}


text:
package io.reactivex;

/**
 * A functional interface that has a {@code subscribe()} method that receives
 * an instance of a {@link MaybeEmitter} instance that allows pushing
 * an event in a cancellation-safe manner.
 *
 * @param <T> the value type pushed
 */
public interface MaybeOnSubscribe<T> {

    /**
     * Called for each MaybeObserver that subscribes.
     * @param e the safe emitter instance, never null
     * @throws Exception on error
     */
    void subscribe(MaybeEmitter<T> e) throws Exception;
}


text:
package org.jboss.hal.testsuite.test.configuration.messaging.server.clustering;

import java.io.IOException;

import org.jboss.arquillian.junit.Arquillian;
import org.jboss.hal.resources.Ids;
import org.jboss.hal.testsuite.fragment.FormFragment;
import org.jboss.hal.testsuite.fragment.TableFragment;
import org.junit.AfterClass;
import org.junit.Before;
import org.junit.BeforeClass;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.wildfly.extras.creaper.core.online.operations.OperationException;
import org.wildfly.extras.creaper.core.online.operations.Values;

import static org.jboss.hal.dmr.ModelDescriptionConstants.HTTP;
import static org.jboss.hal.dmr.ModelDescriptionConstants.NAME;
import static org.jboss.hal.dmr.ModelDescriptionConstants.SERVER;
import static org.jboss.hal.dmr.ModelDescriptionConstants.SOCKET_BINDING;
import static org.jboss.hal.resources.Ids.ITEM;
import static org.jboss.hal.testsuite.fixtures.MessagingFixtures.DG_CREATE;
import static org.jboss.hal.testsuite.fixtures.MessagingFixtures.DG_DELETE;
import static org.jboss.hal.testsuite.fixtures.MessagingFixtures.DG_UPDATE;
import static org.jboss.hal.testsuite.fixtures.MessagingFixtures.REFRESH_TIMEOUT;
import static org.jboss.hal.testsuite.fixtures.MessagingFixtures.SRV_UPDATE;
import static org.jboss.hal.testsuite.fixtures.MessagingFixtures.serverAddress;
import static org.jboss.hal.testsuite.fixtures.MessagingFixtures.socketDiscoveryGroupAddress;

@RunWith(Arquillian.class)
public class SocketDiscoveryGroupTest extends AbstractClusteringTest {

    private static final String MESSAGING_DISCOVERY_GROUP = "messaging-discovery-group";
    private static final String MESSAGING_SOCKET_DISCOVERY_GROUP = "msg-socket-discovery-group";

    @BeforeClass
    public static void createResources() throws IOException {
        createServer(SRV_UPDATE);
        operations.add(socketDiscoveryGroupAddress(SRV_UPDATE, DG_UPDATE),
                Values.of(SOCKET_BINDING, HTTP)).assertSuccess();
        // operations.add(socketDiscoveryGroupAddress(SRV_UPDATE, DG_UPDATE_ALTERNATIVES),
        //         Values.of(SOCKET_BINDING, HTTP)).assertSuccess();
        operations.add(socketDiscoveryGroupAddress(SRV_UPDATE, DG_DELETE),
                Values.of(SOCKET_BINDING, HTTP)).assertSuccess();
    }

    @AfterClass
    public static void removeResources() throws IOException, OperationException {
        operations.removeIfExists(serverAddress(SRV_UPDATE));
    }

    @Before
    public void setUp() throws Exception {
        page.navigate(SERVER, SRV_UPDATE);
    }

    @Test
    public void discoveryGroupCreate() throws Exception {
        console.verticalNavigation().selectSecondary(Ids.build(MESSAGING_DISCOVERY_GROUP, ITEM),
                Ids.build(MESSAGING_SOCKET_DISCOVERY_GROUP, ITEM));
        TableFragment table = page.getSocketDiscoveryGroupTable();
        FormFragment form = page.getSocketDiscoveryGroupForm();
        table.bind(form);

        crudOperations.create(socketDiscoveryGroupAddress(SRV_UPDATE, DG_CREATE), table, formFragment -> {
            formFragment.text(NAME, DG_CREATE);
            formFragment.text(SOCKET_BINDING, HTTP);
        });
    }

    @Test
    public void discoveryGroupUpdate() throws Exception {
        console.verticalNavigation().selectSecondary(Ids.build(MESSAGING_DISCOVERY_GROUP, ITEM),
                Ids.build(MESSAGING_SOCKET_DISCOVERY_GROUP, ITEM));
        TableFragment table = page.getSocketDiscoveryGroupTable();
        FormFragment form = page.getSocketDiscoveryGroupForm();
        table.bind(form);
        table.select(DG_UPDATE);
        crudOperations.update(socketDiscoveryGroupAddress(SRV_UPDATE, DG_UPDATE), form, REFRESH_TIMEOUT, 123L);
    }

    @Test
    public void discoveryGroupRemove() throws Exception {
        console.verticalNavigation().selectSecondary(Ids.build(MESSAGING_DISCOVERY_GROUP, ITEM),
                Ids.build(MESSAGING_SOCKET_DISCOVERY_GROUP, ITEM));
        TableFragment table = page.getSocketDiscoveryGroupTable();
        FormFragment form = page.getSocketDiscoveryGroupForm();
        table.bind(form);

        crudOperations.delete(socketDiscoveryGroupAddress(SRV_UPDATE, DG_DELETE), table, DG_DELETE);
    }

}


text:
package store

import (
	"log"

	"github.com/dgraph-io/badger"
)

// Badger badger.KV db store
type Badger struct {
	db *badger.DB
}

// OpenBadger open Badger store
func OpenBadger(dbPath string) (Store, error) {
	// err := os.MkdirAll(dbPath, 0777)
	// if err != nil {
	// 	log.Fatal("os.MkdirAll: ", err)
	// 	os.Exit(1)
	// }
	// os.MkdirAll(path.Dir(dbPath), os.ModePerm)

	opt := badger.DefaultOptions
	opt.Dir = dbPath
	opt.ValueDir = dbPath
	opt.SyncWrites = true
	kv, err := badger.Open(opt)
	if err != nil {
		log.Fatal("badger NewKV: ", err)
	}

	return &Badger{kv}, err
}

// WALName is useless for this kv database
func (s *Badger) WALName() string {
	return "" // 对于此数据库,本函数没用~
}

// Set sets the provided value for a given key.
// If key is not present, it is created. If it is present,
// the existing value is overwritten with the one provided.
func (s *Badger) Set(k, v []byte) error {
	err := s.db.Update(func(txn *badger.Txn) error {
		// return txn.Set(k, v, 0x00)
		return txn.Set(k, v)
	})

	return err
}

// Get looks for key and returns a value.
// If key is not found, value is nil.
func (s *Badger) Get(k []byte) ([]byte, error) {
	var ival []byte
	err := s.db.View(func(txn *badger.Txn) error {
		item, err := txn.Get(k)
		if err != nil {
			return err
		}

		ival, err = item.Value()
		return err
	})

	return ival, err
}

// Delete deletes a key. Exposing this so that user does not
// have to specify the Entry directly. For example, BitDelete
// seems internal to badger.
func (s *Badger) Delete(k []byte) error {
	err := s.db.Update(func(txn *badger.Txn) error {
		return txn.Delete(k)
	})

	return err
}

// Has returns true if the DB does contains the given key.
func (s *Badger) Has(k []byte) (bool, error) {
	// return s.db.Exists(k)
	val, err := s.Get(k)
	if string(val) == "" && err != nil {
		return false, err
	}

	return true, err
}

// Len returns the size of lsm and value log files in bytes.
// It can be used to decide how often to call RunValueLogGC.
func (s *Badger) Len() (int64, int64) {
	return s.db.Size()
}

// ForEach get all key and value
func (s *Badger) ForEach(fn func(k, v []byte) error) error {
	err := s.db.View(func(txn *badger.Txn) error {
		opts := badger.DefaultIteratorOptions
		opts.PrefetchSize = 1000
		it := txn.NewIterator(opts)
		defer it.Close()
		for it.Rewind(); it.Valid(); it.Next() {
			item := it.Item()
			key := item.Key()
			val, err := item.Value()
			if err != nil {
				return err
			}

			if err := fn(key, val); err != nil {
				return err
			}
		}
		return nil
	})

	return err
}

// Close closes a KV. It's crucial to call it to ensure
// all the pending updates make their way to disk.
func (s *Badger) Close() error {
	return s.db.Close()
}


text:
$(document).ready(function() {
  if (typeof prettyPrint == 'function') {
    $('pre.ruby').addClass('prettyprint lang-rb');
    prettyPrint();
  }

  if ($("[data-restricted='true']").length > 0)
  {
    if (localStorage.getItem('data-restricted') == 'true')
    {
      $("[data-restricted='true']").toggleClass("invisible");
      $("[data-trigger='data-restricted']").html($("[data-trigger='data-restricted']").html().replace("Show", "Hide"));
    }
  }

  $("[data-trigger]").click(function(e) {
    var target = $(this).attr("data-trigger");
    var localStorageTarget = target;

    $("[" + target + "='true']").toggleClass("invisible");
    content = $(this).html();
    if (content.search("Hide") >= 0)
    {
      $(this).html(content.replace("Hide", "Show"));
      localStorage.setItem(localStorageTarget, null);
    }
    else if (content.search("Show") >= 0)
    {
      $(this).html(content.replace("Show", "Hide"));
      localStorage.setItem(localStorageTarget, "true");
    }
  });

  if ($("#page-menu").length > 0 && window.innerWidth >= 1200) {
    var active = $("body").attr("data-active")
    var menu = $("

")

    $("h2[id]").each(function(){
      menu.append("
" + $(this).html() + "
")
    });

    $("#page-menu li.link-to-" + active).append(menu)
    $('body').scrollspy({ target: '#page-menu' })
  }

});


text:
package org.onvif.ver10.device.wsdl;

import java.util.ArrayList;
import java.util.List;
import javax.xml.bind.annotation.XmlAccessType;
import javax.xml.bind.annotation.XmlAccessorType;
import javax.xml.bind.annotation.XmlElement;
import javax.xml.bind.annotation.XmlRootElement;
import javax.xml.bind.annotation.XmlType;
import org.apache.commons.lang3.builder.ToStringBuilder;
import org.apache.cxf.xjc.runtime.JAXBToStringStyle;
import org.onvif.ver10.schema.NetworkProtocol;

/**
 *
Java class for anonymous complex type.
 *
 *
The following schema fragment specifies the expected content contained within this class.
 *
 *

 * <complexType>
 *   <complexContent>
 *     <restriction base="{http://www.w3.org/2001/XMLSchema}anyType">
 *       <sequence>
 *         <element name="NetworkProtocols" type="{http://www.onvif.org/ver10/schema}NetworkProtocol" maxOccurs="unbounded" minOccurs="0"/>
 *       </sequence>
 *     </restriction>
 *   </complexContent>
 * </complexType>
 *

 *
 *
 */
@XmlAccessorType(XmlAccessType.FIELD)
@XmlType(name = "", propOrder = {
    "networkProtocols"
})
@XmlRootElement(name = "GetNetworkProtocolsResponse")
public class GetNetworkProtocolsResponse {

    @XmlElement(name = "NetworkProtocols")
    protected List<NetworkProtocol> networkProtocols;

    /**
     * Gets the value of the networkProtocols property.
     *
     *

     * This accessor method returns a reference to the live list,
     * not a snapshot. Therefore any modification you make to the
     * returned list will be present inside the JAXB object.
     * This is why there is not a set method for the networkProtocols property.
     *
     *

     * For example, to add a new item, do as follows:
     *

     *    getNetworkProtocols().add(newItem);
     *

     *
     *
     *

     * Objects of the following type(s) are allowed in the list
     * {@link NetworkProtocol }
     *
     *
     */
    public List<NetworkProtocol> getNetworkProtocols() {
        if (networkProtocols == null) {
            networkProtocols = new ArrayList<NetworkProtocol>();
        }
        return this.networkProtocols;
    }

    /**
     * Generates a String representation of the contents of this type.
     * This is an extension method, produced by the 'ts' xjc plugin
     *
     */
    @Override
    public String toString() {
        return ToStringBuilder.reflectionToString(this, JAXBToStringStyle.DEFAULT_STYLE);
    }

}


text:
/*
 * Context, defines the interface of interest to clients and has internal states that define its behavior
 */
public class Wolf {
    private State state;

    public Wolf() {
        state = new SleepState();
    }

    public void setState(State state) {
        this.state = state;
    }

    public State getState() {
        return state;
    }

    public void action() {
        state.handle();
    }

    public void passTime() {
        System.out.println("8 hours assed....");
        if(state.getClass().equals(SleepState.class)) {
            setState(new HungerState());
        } else {
            setState(new SleepState());
        }
    }
}


text:
require 'spec_helper'

describe "the empty function" do
  let(:scope) { PuppetlabsSpec::PuppetInternals.scope }
  it "should exist" do
    Puppet::Parser::Functions.function("empty").should == "function_empty"
  end

  it "should raise a ParseError if there is less than 1 arguments" do
    lambda { scope.function_empty([]) }.should( raise_error(Puppet::ParseError))
  end

  it "should return a true for an empty string" do
    result = scope.function_empty([''])
    result.should(eq(true))
  end

  it "should return a false for a non-empty string" do
    result = scope.function_empty(['asdf'])
    result.should(eq(false))
  end
end


text:
/** @file
 * @brief System module to support early Atmel SAM V71 MCU configuration
 */

#include <device.h>
#include <init.h>
#include <soc.h>
#include <arch/cpu.h>

/**
 * @brief Perform SoC configuration at boot.
 *
 * This should be run early during the boot process but after basic hardware
 * initialization is done.
 *
 * @return 0
 */
static int atmel_samv71_config(const struct device *dev)
{
#ifdef CONFIG_SOC_ATMEL_SAMV71_DISABLE_ERASE_PIN
	/* Disable ERASE function on PB12 pin, this is controlled by Bus
	 * Matrix
	 */
	MATRIX->CCFG_SYSIO |= CCFG_SYSIO_SYSIO12;
#endif

	/* In Cortex-M based SoCs JTAG interface can be used to perform
	 * IEEE1149.1 JTAG Boundary scan only. It can not be used as a debug
	 * interface therefore there is no harm done by disabling the JTAG TDI
	 * pin by default.
	 */
	/* Disable TDI function on PB4 pin, this is controlled by Bus Matrix
	 */
	MATRIX->CCFG_SYSIO |= CCFG_SYSIO_SYSIO4;

#ifdef CONFIG_LOG_BACKEND_SWO
	/* Disable PCK3 clock used by ETM module */
	PMC->PMC_SCDR = PMC_SCDR_PCK3;
	while ((PMC->PMC_SCSR) & PMC_SCSR_PCK3) {
		;
	}
	/* Select PLLA clock as PCK3 clock */
	PMC->PMC_PCK[3] = PMC_MCKR_CSS_PLLA_CLK;
	/* Enable PCK3 clock */
	PMC->PMC_SCER = PMC_SCER_PCK3;
	/* Wait for PCK3 setup to complete */
	while (!((PMC->PMC_SR) & PMC_SR_PCKRDY3)) {
		;
	}
#endif

	return 0;
}

SYS_INIT(atmel_samv71_config, PRE_KERNEL_1, 1);


text:
MODULE_big = pg_hibernator
OBJS = pg_hibernate.o pg_hibernate_9.3.o misc.o

PG_CONFIG = pg_config

# Get the version string from pg_config
VERSION := $(shell $(PG_CONFIG) --version | awk '{print $$2}')
ifeq ("$(VERSION)","")
$(error pg_config not found)
endif

# Extract major version and convert to integer, e.g. 9.1.4 -> 901
INTVERSION := $(shell echo $$(($$(echo $(VERSION) | sed 's/\([[:digit:]]\{1,\}\)\.\([[:digit:]]\{1,\}\).*/\1*100+\2/'))))

# We support PostgreSQL 9.3 and later.
ifeq ($(shell echo $$(($(INTVERSION) < 903))),1)
$(error pg_hibernator requires PostgreSQL 9.3 or later. This is $(VERSION))
endif

PGXS := $(shell $(PG_CONFIG) --pgxs)
include $(PGXS)


text:
/**
 * Created with JetBrains RubyMine.
 * User: teamco
 * Date: 11/17/12
 * Time: 5:28 PM
 * To change this template use File | Settings | File Templates.
 */

defineP([
  'modules/Event'
], function defineSiteConfigEventManager(BaseEvent) {

  /**
   * Define SiteConfig event manager
   * @class SiteConfigEventManager
   * @constructor
   * @extends BaseEvent
   */
  var SiteConfigEventManager = function SiteConfigEventManager() {

    /**
     * Define events
     * @property SiteConfigEventManager
     * @type {{}}
     */
    this.events = {};

    /**
     * Set subscribed flag
     * @property SiteConfigEventManager
     * @type {boolean}
     */
    this.subscribed = false;
  };

  return SiteConfigEventManager.extend('SiteConfigEventManager', {

    /**
     * Define event list
     * @memberOf SiteConfigEventManager
     * @type {{
         *      updateTranslations: string,
         *      loadModuleContent: string,
         *      cleanUpLocalStorage: string,
         *      importSiteData: string,
         *      approveImportSiteData: string,
         *      readyToImportSiteData: string,
         *      exportSiteData: string,
         *      loadSitePreferences: string,
         *      widgetGenerator: string,
         *      widgetEditor: string,
         *      setRoutes: string,
         *      activateStorage: string,
         *      publishStorage: string
         * }}
     */
    eventList: {
      updateTranslations: 'update.translations',
      loadModuleContent: 'load.content',
      cleanUpLocalStorage: 'clean.up.local.storage',
      importSiteData: 'import.site.data',
      approveImportSiteData: 'approve.import.site.data',
      readyToImportSiteData: 'ready.to.import.site.data',
      exportSiteData: 'export.site.data',
      loadSitePreferences: 'load.site.preferences',
      widgetGenerator: 'widget.generator',
      widgetEditor: 'widget.editor',
      setRoutes: 'set.routes',
      activateStorage: 'activate.storage',
      publishStorage: 'publish.storage'
    },

    /**
     * Subscribe publish on
     * @memberOf SiteConfigEventManager
     * @param {Application} root
     * @param {Function} [callback]
     * @returns {{}|boolean}
     */
    subscribePublishOn: function subscribePublishOn(root, callback) {

      if (this.subscribed) {
        this.scope.logger.debug(
            'Events already subscribed',
            arguments
        );
        return false;
      }

      /**
       * Set subscribed flag
       * @property SiteConfigEventManager
       * @type {boolean}
       */
      this.subscribed = true;

      /**
       * Define event list
       * @type {*}
       */
      var rootEventList = root.eventManager.eventList;

      /**
       * Define events
       * @type {{scope: Page, events: {eventName: string}[], callback:
       *     Function}}
       */
      var publish = {
        scope: root,
        events: [
          {eventName: rootEventList.afterUpdateStorage}
        ],
        callback: callback
      };

      this.publishOn(publish);
    }

  }, BaseEvent.prototype);
});


text:
package com.graphhopper.matching.gpx;

import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
import com.fasterxml.jackson.dataformat.xml.annotation.JacksonXmlElementWrapper;
import com.fasterxml.jackson.dataformat.xml.annotation.JacksonXmlProperty;
import com.graphhopper.matching.Observation;
import com.graphhopper.util.shapes.GHPoint3D;

import javax.validation.constraints.NotNull;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Optional;

@JsonIgnoreProperties(ignoreUnknown = true)
public class Trk {

    @JacksonXmlElementWrapper(useWrapping = false)
    public List<Trkseg> trkseg = new ArrayList<>();
    public String name;

    public List<Observation> getEntries() {
        ArrayList<Observation> gpxEntries = new ArrayList<>();
        for (Trkseg t : trkseg) {
            for (Trkpt trkpt : t.trkpt) {
                gpxEntries.add(new Observation(new GHPoint3D(trkpt.lat, trkpt.lon, trkpt.ele)));
            }
        }
        return gpxEntries;
    }

    public Optional<Date> getStartTime() {
        return trkseg.stream().flatMap(trkseg -> trkseg.trkpt.stream()).findFirst().flatMap(trkpt -> Optional.ofNullable(trkpt.time));
    }

}


text:
namespace NEventStore.Persistence
{
    using System;
    using System.Collections.Generic;
    using System.Linq;
    using System.Threading.Tasks;
    using NEventStore.Logging;
    using ALinq;

    public class PipelineHooksAwarePersistanceDecorator : IPersistStreams
    {
		private static readonly ILog Logger = LogFactory.BuildLogger(typeof(PipelineHooksAwarePersistanceDecorator));
        private readonly IPersistStreams _original;
        private readonly IEnumerable<IPipelineHook> _pipelineHooks;

        public PipelineHooksAwarePersistanceDecorator(IPersistStreams original, IEnumerable<IPipelineHook> pipelineHooks)
        {
            if (original == null)
            {
                throw new ArgumentNullException("original");
            }
            if (pipelineHooks == null)
            {
                throw new ArgumentNullException("pipelineHooks");
            }
            _original = original;
            _pipelineHooks = pipelineHooks;
        }

        public void Dispose()
        {
            _original.Dispose();
        }

		public IAsyncEnumerable<ICommit> GetFrom(string bucketId, string streamId, int minRevision, int maxRevision)
        {
			return ExecuteHooks(_original.GetFrom(bucketId, streamId, minRevision, maxRevision));
        }

		public Task<ICommit> Commit(CommitAttempt attempt)
        {
            return _original.Commit(attempt);
        }

		public Task<ISnapshot> GetSnapshot(string bucketId, string streamId, int maxRevision)
        {
            return _original.GetSnapshot(bucketId, streamId, maxRevision);
        }

		public Task<bool> AddSnapshot(ISnapshot snapshot)
        {
            return _original.AddSnapshot(snapshot);
        }

		public IAsyncEnumerable<IStreamHead> GetStreamsToSnapshot(string bucketId, int maxThreshold)
        {
            return _original.GetStreamsToSnapshot(bucketId, maxThreshold);
        }

		public Task Initialize()
        {
			return _original.Initialize();
        }

		public IAsyncEnumerable<ICommit> GetFrom(string bucketId, DateTime start)
        {
			return ExecuteHooks(_original.GetFrom(bucketId, start));
        }

		public IAsyncEnumerable<ICommit> GetFrom(string checkpointToken)
        {
			return ExecuteHooks(_original.GetFrom(checkpointToken));
        }

        public IAsyncEnumerable<ICommit> GetFrom(string bucketId, string checkpointToken)
        {
            return ExecuteHooks(_original.GetFrom(bucketId, checkpointToken));
        }
        public Task<ICheckpoint> GetCheckpoint(string checkpointToken)
        {
            return _original.GetCheckpoint(checkpointToken);
        }

		public IAsyncEnumerable<ICommit> GetFromTo(string bucketId, DateTime start, DateTime end)
        {
			return ExecuteHooks(_original.GetFromTo(bucketId, start, end));
        }

		public async Task Purge()
        {
			await _original.Purge();
            foreach (var pipelineHook in _pipelineHooks)
            {
                pipelineHook.OnPurge();
            }
        }

		public async Task Purge(string bucketId)
        {
			await _original.Purge(bucketId);
            foreach (var pipelineHook in _pipelineHooks)
            {
				await pipelineHook.OnPurge(bucketId);
            }
        }

		public Task Drop()
        {
			return _original.Drop();
        }

		public async Task DeleteStream(string bucketId, string streamId)
        {
			await _original.DeleteStream(bucketId, streamId);
            foreach (var pipelineHook in _pipelineHooks)
            {
				await pipelineHook.OnDeleteStream(bucketId, streamId);
            }
        }

        public bool IsDisposed
        {
			get
			{
				return _original.IsDisposed;
			}
        }

		private IAsyncEnumerable<ICommit> ExecuteHooks(IAsyncEnumerable<ICommit> commits)
        {
            return AsyncEnumerable.Create<ICommit>(async producer =>
            {
                //List<ICommit> results = new List<ICommit>();
                await commits.ForEach(async context =>
                {
                    var commit = context.Item;
                    var filtered = commit;
                    foreach (var hook in _pipelineHooks)
                    {
                        filtered = await hook.Select(filtered);
                        if (filtered == null)
                        {
                            Logger.Info(Resources.PipelineHookSkippedCommit, hook.GetType(), commit.CommitId);
                            break;
                        }
                    }

                    if (filtered == null)
                    {
                        Logger.Info(Resources.PipelineHookFilteredCommit);
                    }
                    else
                    {
                        await producer.Yield(filtered);
                    }
                });
                //return results;
            });

        }
    }
}


text:
package org.apache.hadoop.hbase.master;

import java.io.IOException;

import org.apache.hadoop.hbase.TableNotDisabledException;
import org.apache.hadoop.hbase.TableNotFoundException;
import org.apache.hadoop.hbase.executor.ExecutorService;

/**
 * Services Master supplies
 */
public interface MasterServices {
  /**
   * @return Master's instance of the {@link AssignmentManager}
   */
  public AssignmentManager getAssignmentManager();

  /**
   * @return Master's filesystem {@link MasterFileSystem} utility class.
   */
  public MasterFileSystem getMasterFileSystem();

  /**
   * @return Master's {@link ServerManager} instance.
   */
  public ServerManager getServerManager();

  /**
   * @return Master's instance of {@link ExecutorService}
   */
  public ExecutorService getExecutorService();

  /**
   * Check table is modifiable; i.e. exists and is offline.
   * @param tableName Name of table to check.
   * @throws TableNotDisabledException
   * @throws TableNotFoundException
   */
  public void checkTableModifiable(final byte [] tableName) throws IOException;
}


text:
<?php

$path = dirname(dirname(__FILE__));
require_once($path . '/vendor/autoload.php');

use ZillowApi\ZillowApiClient;

$client = new ZillowApiClient('xxxxx');

try {
	$response = $client->execute('GetZestimate', ['zpid' => 84074482]);

    if($response->isSuccessful()) {
        print_r($response->getData());
    } else {
        echo $response->getCode() . ':' . $response->getMessage();
    }
} catch(\Exception $e) {
	echo $e->getMessage();
}


text:
module OmfCommon
class Comm
class XMPP
  class Topic < OmfCommon::Comm::Topic
#    def delete_on_message_cbk_by_id(id)
#      @lock.synchronize do
#        @on_message_cbks[id] && @on_message_cbks.reject! { |k| k == id.to_s }
#      end
#    end

    def address
      #"xmpp://#{id.to_s}@#{OmfCommon.comm.jid.domain}"
      "xmpp://#{id.to_s}@#{@pubsub_domain}"
    end

    def on_subscribed(&block)
      return unless block

      @lock.synchronize do
        @on_subscrided_handlers << block
      end
    end

    def unsubscribe(key)
      super
      OmfCommon.comm._unsubscribe_one(self.id)
    end

    private

    def pubsub_domain_addr
      "pubsub.#{@pubsub_domain}"
    end

    def initialize(id, opts = {}, &block)
      id, @pubsub_domain = id.to_s.split("@")
      if id =~ /^xmpp:\/\/(.+)$/
        id = $1
      end
      @pubsub_domain ||= OmfCommon.comm.jid.domain

      super

      @on_subscrided_handlers = []

      topic_block = proc do |stanza|
        if stanza.error?
          block.call(stanza) if block
        else
          block.call(self) if block

          @lock.synchronize do
            @on_subscrided_handlers.each do |handler|
              handler.call
            end
          end
        end
      end

      # Create xmpp pubsub topic, then subscribe to it
      #
      OmfCommon.comm._create(id.to_s, pubsub_domain_addr) do |stanza|
        if stanza.error?
          e_stanza = Blather::StanzaError.import(stanza)
          if e_stanza.name == :conflict
            # Topic exists, just subscribe to it.
            OmfCommon.comm._subscribe(id.to_s, pubsub_domain_addr, &topic_block)
          else
            block.call(stanza) if block
          end
        else
          OmfCommon.comm._subscribe(id.to_s, pubsub_domain_addr, &topic_block)
        end
      end

      event_block = proc do |event|
        OmfCommon::Message.parse(event.items.first.payload) do |parsed_msg|
          on_incoming_message(parsed_msg)
        end
      end

      OmfCommon.comm.topic_event(default_guard, &event_block)
    end

    def _send_message(msg, opts = {}, block)
      super
      OmfCommon.comm.publish(self.id, msg, pubsub_domain_addr)
    end

    def valid_guard?(guard_proc)
      guard_proc && guard_proc.class == Proc
    end

    def default_guard
      proc do |event|
        event.node == self.id.to_s
      end
    end
  end
end
end
end


text:
package net.seapanda.bunnyhop.configfilereader;

import static java.nio.file.FileVisitOption.*;

import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.util.HashMap;
import java.util.Map;
import java.util.stream.Stream;

import net.seapanda.bunnyhop.common.constant.BhParams;
import net.seapanda.bunnyhop.common.tools.MsgPrinter;
import net.seapanda.bunnyhop.common.tools.Util;

/**
 * FXMLファイルとそのパスを保存するクラス
 * @author Koike
 */
public class FXMLCollector {

	public static final FXMLCollector INSTANCE = new FXMLCollector();
	private static final Map<String, Path> fileName_filePath = new HashMap<>();

	private FXMLCollector(){}

	/**
	 * FXMLファイルのファイル名とそのパスを集める
	 * @return FXMLファイルのフォルダが見つからなかった場合 falseを返す
	 */
	public boolean collectFXMLFiles() {

		Path dirPath = Paths.get(Util.INSTANCE.EXEC_PATH, BhParams.Path.VIEW_DIR, BhParams.Path.FXML_DIR);
		Stream<Path> paths;	//読み込むファイルパスリスト
		try {
			paths = Files.walk(dirPath, FOLLOW_LINKS).filter(path -> path.getFileName().toString().endsWith(".fxml")); //.fxmlファイルだけ収集
		}
		catch (IOException e) {
			MsgPrinter.INSTANCE.errMsgForDebug("fxml directory not found " + dirPath + "\n" + e.toString());
			return false;
		}
		paths.forEach(filePath -> fileName_filePath.put(filePath.getFileName().toString(), filePath));
		return true;
	}

	/**
	 * FXMLファイル名からそのファイルのフルパスを取得する
	 * @param fileName フルパスを知りたいFXMLファイル名
	 * @return fileName で指定したファイルのパスオブジェクト. パスが見つからない場合はnullを返す
	 */
	public Path getFilePath(String fileName) {
		return fileName_filePath.getOrDefault(fileName, null);
	}
}


text:
using UnityEngine;
using System.Collections;

public class ChildDS : MonoBehaviour {
    public GameObject parent;
	// Use this for initialization
	void Start () {
        parent = gameObject.transform.parent.gameObject;
	}

	// Update is called once per frame
	void Update () {

    }
    void OnTriggerEnter(Collider col) {
        parent.SendMessage("RedirectedOnTriggerEnter", col);
	}
}